au.gov.amsa.streams

Class OnSubscribeInputStream

java.lang.Object

rx.observables.SyncOnSubscribe<InputStream,byte[]>

au.gov.amsa.streams.OnSubscribeInputStream

All Implemented Interfaces:

rx.functions.Action, rx.functions.Action1<rx.Subscriber<? super byte[]>>, rx.functions.Function, rx.Observable.OnSubscribe<byte[]>

public final class OnSubscribeInputStream
extends rx.observables.SyncOnSubscribe<InputStream,byte[]>

Constructor Summary

Constructors

Constructor and Description
OnSubscribeInputStream(InputStream is, int size)

Method Summary

Modifier and Type	Method and Description
protected InputStream	generateState()
protected InputStream	next(InputStream is, rx.Observer<? super byte[]> observer)
rx.Observable<byte[]>	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

OnSubscribeInputStream

public OnSubscribeInputStream(InputStream is,
                              int size)

Method Detail

generateState

protected InputStream generateState()

Specified by:

generateState in class rx.observables.SyncOnSubscribe<InputStream,byte[]>

next

protected InputStream next(InputStream is,
                           rx.Observer<? super byte[]> observer)

Specified by:

next in class rx.observables.SyncOnSubscribe<InputStream,byte[]>

toObservable

public rx.Observable<byte[]> toObservable()