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 delegates `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 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<java.lang.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<java.lang.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
Constructor	Description
`SubscriptionProducer(Subscriber<? super T> subscriber, SyncOnSubscribe<S,T> parent, S state)`