au.gov.amsa.streams

Class OnSubscribeReader

java.lang.Object

rx.observables.SyncOnSubscribe<Reader,String>

au.gov.amsa.streams.OnSubscribeReader

All Implemented Interfaces:

rx.functions.Action, rx.functions.Action1<rx.Subscriber<? super String>>, rx.functions.Function, rx.Observable.OnSubscribe<String>

public final class OnSubscribeReader
extends rx.observables.SyncOnSubscribe<Reader,String>

Constructor Summary

Constructors

Constructor and Description
OnSubscribeReader(Reader reader, int size)

Method Summary

Modifier and Type	Method and Description
protected Reader	generateState()
protected Reader	next(Reader reader, rx.Observer<? super String> observer)
rx.Observable<String>	toObservable()

Methods inherited from class rx.observables.SyncOnSubscribe

call, createSingleState, createSingleState, createStateful, createStateful, createStateless, createStateless, onUnsubscribe

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OnSubscribeReader

public OnSubscribeReader(Reader reader,
                         int size)

Method Detail

generateState

protected Reader generateState()

Specified by:

generateState in class rx.observables.SyncOnSubscribe<Reader,String>

next

protected Reader next(Reader reader,
                      rx.Observer<? super String> observer)

Specified by:

next in class rx.observables.SyncOnSubscribe<Reader,String>

toObservable

public rx.Observable<String> toObservable()