Package | Description |
---|---|
rx |
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
|
rx.internal.operators |
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
|
rx.plugins |
Callback types and a central plugin handler class to hook into the lifecycle
of the base reactive types and schedulers.
|
Modifier and Type | Method and Description |
---|---|
static <T> Single<T> |
Single.create(Single.OnSubscribe<T> f)
Returns a Single that will execute the specified function when a
SingleSubscriber executes it or
a Subscriber subscribes to it. |
Constructor and Description |
---|
Single(Single.OnSubscribe<T> f)
Creates a Single with a Function to execute when it is subscribed to (executed).
|
Modifier and Type | Class and Description |
---|---|
class |
OnSubscribeOnAssemblySingle<T>
Captures the current stack when it is instantiated, makes
it available through a field and attaches it to all
passing exception.
|
class |
OnSubscribeSingle<T>
Allows conversion of an Observable to a Single ensuring that exactly one item is emitted - no more and no less.
|
class |
SingleDelay<T>
Signal the success or error value on the Scheduler's thread.
|
class |
SingleDoAfterTerminate<T>
Execute an action after onSuccess or onError has been delivered.
|
class |
SingleDoOnEvent<T> |
class |
SingleDoOnSubscribe<T>
Call an Action0 when the subscription happens to the source.
|
class |
SingleDoOnUnsubscribe<T>
Call an Action0 when the subscription happens to the source.
|
class |
SingleFromCallable<T>
Execute a callable and emit its resulting value.
|
class |
SingleFromEmitter<T>
Calls an action with a SingleEmitter instance for each individual subscribers that
generates a terminal signal (eventually).
|
class |
SingleFromFuture<T>
Wait and emit the value of the Future.
|
class |
SingleFromObservable<T>
Wrap an Observable.OnSubscribe and expose it as a Single.OnSubscribe.
|
class |
SingleLiftObservableOperator<T,R>
Lift an Observable.Operator into the Single sequence.
|
class |
SingleObserveOn<T>
Signal the success or error value on the Scheduler's thread.
|
class |
SingleOnErrorReturn<T>
Signal a value returned by a resumeFunction when the source signals a Throwable.
|
class |
SingleOnSubscribeDelaySubscriptionOther<T>
Delays the subscription to the Single until the Observable
fires an event or completes.
|
class |
SingleOnSubscribeMap<T,R>
Applies a function of your choosing to every item emitted by an
Single , and emits the results of
this transformation as a new Single . |
class |
SingleOnSubscribeUsing<T,Resource>
Generates a resource, derives a Single from it and disposes that resource once the
Single terminates.
|
class |
SingleOperatorOnErrorResumeNext<T> |
class |
SingleTakeUntilCompletable<T>
Relay the source signals if the other doesn't terminate before.
|
class |
SingleTakeUntilObservable<T,U>
Relay the source signals if the other doesn't terminate before.
|
class |
SingleTakeUntilSingle<T,U>
Relay the source signals if the other doesn't terminate before.
|
class |
SingleTimeout<T> |
Modifier and Type | Method and Description |
---|---|
static <T> Single.OnSubscribe<T> |
RxJavaHooks.onCreate(Single.OnSubscribe<T> onSubscribe)
Hook to call when a Single is created.
|
<T> Single.OnSubscribe<T> |
RxJavaSingleExecutionHook.onCreate(Single.OnSubscribe<T> f)
Deprecated.
|
static <T> Single.OnSubscribe<T> |
RxJavaHooks.onSingleStart(Single<T> instance,
Single.OnSubscribe<T> onSubscribe)
Hook to call before the child subscriber is subscribed to the OnSubscribe action.
|
Modifier and Type | Method and Description |
---|---|
static Func1<Single.OnSubscribe,Single.OnSubscribe> |
RxJavaHooks.getOnSingleCreate()
Returns the current Single onCreate hook function or null if it is
set to the default pass-through.
|
static Func1<Single.OnSubscribe,Single.OnSubscribe> |
RxJavaHooks.getOnSingleCreate()
Returns the current Single onCreate hook function or null if it is
set to the default pass-through.
|
static Func2<Single,Single.OnSubscribe,Single.OnSubscribe> |
RxJavaHooks.getOnSingleStart()
Returns the current Single onStart hook function or null if it is
set to the default pass-through.
|
static Func2<Single,Single.OnSubscribe,Single.OnSubscribe> |
RxJavaHooks.getOnSingleStart()
Returns the current Single onStart hook function or null if it is
set to the default pass-through.
|
Modifier and Type | Method and Description |
---|---|
static <T> Single.OnSubscribe<T> |
RxJavaHooks.onCreate(Single.OnSubscribe<T> onSubscribe)
Hook to call when a Single is created.
|
<T> Single.OnSubscribe<T> |
RxJavaSingleExecutionHook.onCreate(Single.OnSubscribe<T> f)
Deprecated.
|
static <T> Single.OnSubscribe<T> |
RxJavaHooks.onSingleStart(Single<T> instance,
Single.OnSubscribe<T> onSubscribe)
Hook to call before the child subscriber is subscribed to the OnSubscribe action.
|
Modifier and Type | Method and Description |
---|---|
static void |
RxJavaHooks.setOnSingleCreate(Func1<Single.OnSubscribe,Single.OnSubscribe> onSingleCreate)
Sets the Single onCreate hook function unless a lockdown is in effect.
|
static void |
RxJavaHooks.setOnSingleCreate(Func1<Single.OnSubscribe,Single.OnSubscribe> onSingleCreate)
Sets the Single onCreate hook function unless a lockdown is in effect.
|
static void |
RxJavaHooks.setOnSingleStart(Func2<Single,Single.OnSubscribe,Single.OnSubscribe> onSingleStart)
Sets the hook function that is called when a subscriber subscribes to a Single
unless a lockdown is in effect.
|
static void |
RxJavaHooks.setOnSingleStart(Func2<Single,Single.OnSubscribe,Single.OnSubscribe> onSingleStart)
Sets the hook function that is called when a subscriber subscribes to a Single
unless a lockdown is in effect.
|
Copyright © 2017. All rights reserved.