Uses of Class
rx.observables.AsyncOnSubscribe

Packages that use AsyncOnSubscribe

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 AsyncOnSubscribe in rx

Methods in rx with parameters of type AsyncOnSubscribe

Modifier and Type	Method	Description
static <S, T> Observable<T>	Observable.create(AsyncOnSubscribe<S,T> asyncOnSubscribe)	Returns an Observable that respects the back-pressure semantics.

Uses of AsyncOnSubscribe in rx.observables

Subclasses of AsyncOnSubscribe in rx.observables

Modifier and Type	Class	Description
(package private) static final class	AsyncOnSubscribe.AsyncOnSubscribeImpl<S,T>	An implementation of AsyncOnSubscribe that delegates next(Object, long, Observer), generateState(), and onUnsubscribe(Object) to provided functions/closures.

Fields in rx.observables declared as AsyncOnSubscribe

Modifier and Type	Field	Description
private final AsyncOnSubscribe<S,T>	AsyncOnSubscribe.AsyncOuterManager.parent

Methods in rx.observables that return AsyncOnSubscribe

Modifier and Type	Method	Description
static <S, T> AsyncOnSubscribe<S,T>	AsyncOnSubscribe.createSingleState(Func0<? extends S> generator, Action3<? super S,Long,? super Observer<Observable<? extends T>>> next)	Generates a synchronous AsyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
static <S, T> AsyncOnSubscribe<S,T>	AsyncOnSubscribe.createSingleState(Func0<? extends S> generator, Action3<? super S,Long,? super Observer<Observable<? extends T>>> next, Action1<? super S> onUnsubscribe)	Generates a synchronous AsyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
static <S, T> AsyncOnSubscribe<S,T>	AsyncOnSubscribe.createStateful(Func0<? extends S> generator, Func3<? super S,Long,? super Observer<Observable<? extends T>>,? extends S> next)	Generates a synchronous AsyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
static <S, T> AsyncOnSubscribe<S,T>	AsyncOnSubscribe.createStateful(Func0<? extends S> generator, Func3<? super S,Long,? super Observer<Observable<? extends T>>,? extends S> next, Action1<? super S> onUnsubscribe)	Generates a synchronous AsyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
static <T> AsyncOnSubscribe<Void,T>	AsyncOnSubscribe.createStateless(Action2<Long,? super Observer<Observable<? extends T>>> next)	Generates a synchronous AsyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.
static <T> AsyncOnSubscribe<Void,T>	AsyncOnSubscribe.createStateless(Action2<Long,? super Observer<Observable<? extends T>>> next, Action0 onUnsubscribe)	Generates a synchronous AsyncOnSubscribe that calls the provided next function to generate data to downstream subscribers.

Constructors in rx.observables with parameters of type AsyncOnSubscribe

Modifier	Constructor	Description
	AsyncOuterManager(AsyncOnSubscribe<S,T> parent, S initialState, AsyncOnSubscribe.UnicastSubject<Observable<T>> merger)