Uses of Class
rx.observables.SyncOnSubscribe
-
Packages that use SyncOnSubscribe Package Description rx Base reactive classes: Observable, Single and Completable; base reactive consumers; other common base interfaces.rx.observables Classes extending the Observable base reactive class, synchronous and asynchronous event generators. -
-
Uses of SyncOnSubscribe in rx
Methods in rx with parameters of type SyncOnSubscribe Modifier and Type Method Description static <S,T>
Observable<T>Observable. create(SyncOnSubscribe<S,T> syncOnSubscribe)
Returns an Observable that respects the back-pressure semantics. -
Uses of SyncOnSubscribe in rx.observables
Subclasses of SyncOnSubscribe in rx.observables Modifier and Type Class Description (package private) static class
SyncOnSubscribe.SyncOnSubscribeImpl<S,T>
An implementation of SyncOnSubscribe that delegatesSyncOnSubscribe#next(Object, Subscriber)
,generateState()
, andonUnsubscribe(Object)
to provided functions/closures.Fields in rx.observables declared as SyncOnSubscribe Modifier and Type Field Description private SyncOnSubscribe<S,T>
SyncOnSubscribe.SubscriptionProducer. parent
Methods in rx.observables that return SyncOnSubscribe Modifier and Type Method Description static <S,T>
SyncOnSubscribe<S,T>SyncOnSubscribe. createSingleState(Func0<? extends S> generator, Action2<? super S,? super Observer<? super T>> next)
Generates a synchronousSyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.static <S,T>
SyncOnSubscribe<S,T>SyncOnSubscribe. createSingleState(Func0<? extends S> generator, Action2<? super S,? super Observer<? super T>> next, Action1<? super S> onUnsubscribe)
Generates a synchronousSyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.static <S,T>
SyncOnSubscribe<S,T>SyncOnSubscribe. createStateful(Func0<? extends S> generator, Func2<? super S,? super Observer<? super T>,? extends S> next)
Generates a synchronousSyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.static <S,T>
SyncOnSubscribe<S,T>SyncOnSubscribe. createStateful(Func0<? extends S> generator, Func2<? super S,? super Observer<? super T>,? extends S> next, Action1<? super S> onUnsubscribe)
Generates a synchronousSyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.static <T> SyncOnSubscribe<java.lang.Void,T>
SyncOnSubscribe. createStateless(Action1<? super Observer<? super T>> next)
Generates a synchronousSyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.static <T> SyncOnSubscribe<java.lang.Void,T>
SyncOnSubscribe. createStateless(Action1<? super Observer<? super T>> next, Action0 onUnsubscribe)
Generates a synchronousSyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.Methods in rx.observables with parameters of type SyncOnSubscribe Modifier and Type Method Description private void
SyncOnSubscribe.SubscriptionProducer. nextIteration(SyncOnSubscribe<S,T> parent)
Constructors in rx.observables with parameters of type SyncOnSubscribe Constructor Description SubscriptionProducer(Subscriber<? super T> subscriber, SyncOnSubscribe<S,T> parent, S state)
-