Uses of Class
rx.observables.SyncOnSubscribe
Packages that use SyncOnSubscribe
Package
Description
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
Classes extending the Observable base reactive class, synchronous and
asynchronous event generators.
-
Uses of SyncOnSubscribe in rx
Methods in rx with parameters of type SyncOnSubscribeModifier and TypeMethodDescriptionstatic <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.observablesModifier and TypeClassDescription(package private) static final class
An implementation of SyncOnSubscribe that delegatesinvalid reference
SyncOnSubscribe#next(Object, Subscriber)
generateState()
, andonUnsubscribe(Object)
to provided functions/closures.Fields in rx.observables declared as SyncOnSubscribeModifier and TypeFieldDescriptionprivate final SyncOnSubscribe
<S, T> SyncOnSubscribe.SubscriptionProducer.parent
Methods in rx.observables that return SyncOnSubscribeModifier and TypeMethodDescriptionstatic <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
<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
<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 SyncOnSubscribeModifier and TypeMethodDescriptionprivate void
SyncOnSubscribe.SubscriptionProducer.nextIteration
(SyncOnSubscribe<S, T> parent) Constructors in rx.observables with parameters of type SyncOnSubscribeModifierConstructorDescription(package private)
SubscriptionProducer
(Subscriber<? super T> subscriber, SyncOnSubscribe<S, T> parent, S state)