Uses of Class
rx.observables.AsyncOnSubscribe
Packages that use AsyncOnSubscribe
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 AsyncOnSubscribe in rx
Methods in rx with parameters of type AsyncOnSubscribeModifier and TypeMethodDescriptionstatic <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.observablesModifier and TypeClassDescription(package private) static final class
An implementation of AsyncOnSubscribe that delegatesnext(Object, long, Observer)
,generateState()
, andonUnsubscribe(Object)
to provided functions/closures.Fields in rx.observables declared as AsyncOnSubscribeModifier and TypeFieldDescriptionprivate final AsyncOnSubscribe
<S, T> AsyncOnSubscribe.AsyncOuterManager.parent
Methods in rx.observables that return AsyncOnSubscribeModifier and TypeMethodDescriptionstatic <S,
T> AsyncOnSubscribe <S, T> AsyncOnSubscribe.createSingleState
(Func0<? extends S> generator, Action3<? super S, Long, ? super Observer<Observable<? extends T>>> next) Generates a synchronousAsyncOnSubscribe
that calls the providednext
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 synchronousAsyncOnSubscribe
that calls the providednext
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 synchronousAsyncOnSubscribe
that calls the providednext
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 synchronousAsyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.static <T> AsyncOnSubscribe
<Void, T> AsyncOnSubscribe.createStateless
(Action2<Long, ? super Observer<Observable<? extends T>>> next) Generates a synchronousAsyncOnSubscribe
that calls the providednext
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 synchronousAsyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.Constructors in rx.observables with parameters of type AsyncOnSubscribeModifierConstructorDescriptionAsyncOuterManager
(AsyncOnSubscribe<S, T> parent, S initialState, AsyncOnSubscribe.UnicastSubject<Observable<T>> merger)