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 Completable |
Completable.create(Completable.OnSubscribe onSubscribe)
Constructs a Completable instance by wrapping the given onSubscribe callback.
|
Constructor and Description |
---|
Completable(Completable.OnSubscribe onSubscribe)
Constructs a Completable instance with the given onSubscribe callback.
|
Completable(Completable.OnSubscribe onSubscribe,
boolean useHook)
Constructs a Completable instance with the given onSubscribe callback without calling the onCreate
hook.
|
Modifier and Type | Class and Description |
---|---|
class |
CompletableFlatMapSingleToCompletable<T> |
class |
CompletableFromEmitter
Allows push-based emission of terminal events to a CompletableSubscriber.
|
class |
CompletableOnSubscribeConcat |
class |
CompletableOnSubscribeConcatArray |
class |
CompletableOnSubscribeConcatIterable |
class |
CompletableOnSubscribeMerge |
class |
CompletableOnSubscribeMergeArray |
class |
CompletableOnSubscribeMergeDelayErrorArray |
class |
CompletableOnSubscribeMergeDelayErrorIterable |
class |
CompletableOnSubscribeMergeIterable |
class |
CompletableOnSubscribeTimeout |
class |
OnSubscribeOnAssemblyCompletable<T>
Captures the current stack when it is instantiated, makes
it available through a field and attaches it to all
passing exception.
|
Constructor and Description |
---|
OnSubscribeOnAssemblyCompletable(Completable.OnSubscribe source) |
Modifier and Type | Method and Description |
---|---|
static <T> Completable.OnSubscribe |
RxJavaHooks.onCompletableStart(Completable instance,
Completable.OnSubscribe onSubscribe)
Hook to call before the child subscriber is subscribed to the OnSubscribe action.
|
static Completable.OnSubscribe |
RxJavaHooks.onCreate(Completable.OnSubscribe onSubscribe)
Hook to call when a Completable is created.
|
Completable.OnSubscribe |
RxJavaCompletableExecutionHook.onCreate(Completable.OnSubscribe f)
Deprecated.
|
Completable.OnSubscribe |
RxJavaCompletableExecutionHook.onSubscribeStart(Completable completableInstance,
Completable.OnSubscribe onSubscribe)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static Func1<Completable.OnSubscribe,Completable.OnSubscribe> |
RxJavaHooks.getOnCompletableCreate()
Returns the current Completable onCreate hook function or null if it is
set to the default pass-through.
|
static Func1<Completable.OnSubscribe,Completable.OnSubscribe> |
RxJavaHooks.getOnCompletableCreate()
Returns the current Completable onCreate hook function or null if it is
set to the default pass-through.
|
static Func2<Completable,Completable.OnSubscribe,Completable.OnSubscribe> |
RxJavaHooks.getOnCompletableStart()
Returns the current Completable onStart hook function or null if it is
set to the default pass-through.
|
static Func2<Completable,Completable.OnSubscribe,Completable.OnSubscribe> |
RxJavaHooks.getOnCompletableStart()
Returns the current Completable onStart hook function or null if it is
set to the default pass-through.
|
Modifier and Type | Method and Description |
---|---|
static <T> Completable.OnSubscribe |
RxJavaHooks.onCompletableStart(Completable instance,
Completable.OnSubscribe onSubscribe)
Hook to call before the child subscriber is subscribed to the OnSubscribe action.
|
static Completable.OnSubscribe |
RxJavaHooks.onCreate(Completable.OnSubscribe onSubscribe)
Hook to call when a Completable is created.
|
Completable.OnSubscribe |
RxJavaCompletableExecutionHook.onCreate(Completable.OnSubscribe f)
Deprecated.
|
Completable.OnSubscribe |
RxJavaCompletableExecutionHook.onSubscribeStart(Completable completableInstance,
Completable.OnSubscribe onSubscribe)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static void |
RxJavaHooks.setOnCompletableCreate(Func1<Completable.OnSubscribe,Completable.OnSubscribe> onCompletableCreate)
Sets the Completable's onCreate hook function unless a lockdown is in effect.
|
static void |
RxJavaHooks.setOnCompletableCreate(Func1<Completable.OnSubscribe,Completable.OnSubscribe> onCompletableCreate)
Sets the Completable's onCreate hook function unless a lockdown is in effect.
|
static void |
RxJavaHooks.setOnCompletableStart(Func2<Completable,Completable.OnSubscribe,Completable.OnSubscribe> onCompletableStart)
Sets the hook function that is called when a subscriber subscribes to a Completable
unless a lockdown is in effect.
|
static void |
RxJavaHooks.setOnCompletableStart(Func2<Completable,Completable.OnSubscribe,Completable.OnSubscribe> onCompletableStart)
Sets the hook function that is called when a subscriber subscribes to a Completable
unless a lockdown is in effect.
|
Copyright © 2017. All rights reserved.