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 final class	SyncOnSubscribe.SyncOnSubscribeImpl<S,T>	An implementation of SyncOnSubscribe that delegates invalid reference SyncOnSubscribe#next(Object, Subscriber) , generateState(), and onUnsubscribe(Object) to provided functions/closures.

Fields in rx.observables declared as SyncOnSubscribe

Modifier and Type	Field	Description
private final 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 synchronous SyncOnSubscribe that calls the provided next 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 synchronous SyncOnSubscribe that calls the provided next 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 synchronous SyncOnSubscribe that calls the provided next 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 synchronous SyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
static <T> SyncOnSubscribe<Void,T>	SyncOnSubscribe.createStateless(Action1<? super Observer<? super T>> next)	Generates a synchronous SyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
static <T> SyncOnSubscribe<Void,T>	SyncOnSubscribe.createStateless(Action1<? super Observer<? super T>> next, Action0 onUnsubscribe)	Generates a synchronous SyncOnSubscribe that calls the provided next 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

Modifier	Constructor	Description
(package private)	SubscriptionProducer(Subscriber<? super T> subscriber, SyncOnSubscribe<S,T> parent, S state)