Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
io.reactivex.internal.disposables | |
io.reactivex.internal.observers | |
io.reactivex.internal.operators.completable | |
io.reactivex.internal.operators.flowable | |
io.reactivex.internal.operators.maybe | |
io.reactivex.internal.operators.mixed | |
io.reactivex.internal.operators.observable | |
io.reactivex.internal.operators.single | |
io.reactivex.internal.util | |
io.reactivex.observers |
Default wrappers and implementations for Observer-based consumer classes and interfaces,
including disposable and resource-tracking variants and
the
TestObserver that allows unit testing
Observable -, Single -, Maybe -
and Completable -based flows. |
io.reactivex.plugins |
Contains the central plugin handler
RxJavaPlugins
class to hook into the lifecycle of the base reactive types and schedulers. |
io.reactivex.subjects |
Classes representing so-called hot sources, aka subjects, that implement a base reactive class and
the respective consumer type at once to allow forms of multicasting events to multiple
consumers as well as consuming another base reactive type of their kind.
|
Modifier and Type | Method and Description |
---|---|
<E extends SingleObserver<? super T>> |
Single.subscribeWith(E observer)
Subscribes a given SingleObserver (subclass) to this Single and returns the given
SingleObserver as is.
|
Modifier and Type | Method and Description |
---|---|
SingleObserver<? super Upstream> |
SingleOperator.apply(SingleObserver<? super Downstream> observer)
Applies a function to the child SingleObserver and returns a new parent SingleObserver.
|
Modifier and Type | Method and Description |
---|---|
SingleObserver<? super Upstream> |
SingleOperator.apply(SingleObserver<? super Downstream> observer)
Applies a function to the child SingleObserver and returns a new parent SingleObserver.
|
void |
SingleSource.subscribe(SingleObserver<? super T> observer)
Subscribes the given SingleObserver to this SingleSource instance.
|
void |
Single.subscribe(SingleObserver<? super T> observer) |
protected abstract void |
Single.subscribeActual(SingleObserver<? super T> observer)
Implement this method in subclasses to handle the incoming
SingleObserver s. |
Modifier and Type | Method and Description |
---|---|
static void |
EmptyDisposable.error(Throwable e,
SingleObserver<?> observer) |
Modifier and Type | Class and Description |
---|---|
class |
BiConsumerSingleObserver<T> |
class |
BlockingMultiObserver<T>
A combined Observer that awaits the success or error signal via a CountDownLatch.
|
class |
ConsumerSingleObserver<T> |
class |
FutureSingleObserver<T>
An Observer + Future that expects exactly one upstream value and provides it
via the (blocking) Future API.
|
class |
ResumeSingleObserver<T>
A SingleObserver implementation used for subscribing to the actual SingleSource
and replace the current Disposable in a parent AtomicReference.
|
Constructor and Description |
---|
ResumeSingleObserver(AtomicReference<Disposable> parent,
SingleObserver<? super T> downstream) |
Modifier and Type | Method and Description |
---|---|
protected void |
CompletableMaterialize.subscribeActual(SingleObserver<? super Notification<T>> observer) |
protected void |
CompletableToSingle.subscribeActual(SingleObserver<? super T> observer) |
Modifier and Type | Method and Description |
---|---|
void |
FlowableSequenceEqualSingle.subscribeActual(SingleObserver<? super Boolean> observer) |
protected void |
FlowableAnySingle.subscribeActual(SingleObserver<? super Boolean> observer) |
protected void |
FlowableAllSingle.subscribeActual(SingleObserver<? super Boolean> observer) |
protected void |
FlowableCountSingle.subscribeActual(SingleObserver<? super Long> observer) |
protected void |
FlowableReduceWithSingle.subscribeActual(SingleObserver<? super R> observer) |
protected void |
FlowableReduceSeedSingle.subscribeActual(SingleObserver<? super R> observer) |
protected void |
FlowableSingleSingle.subscribeActual(SingleObserver<? super T> observer) |
protected void |
FlowableLastSingle.subscribeActual(SingleObserver<? super T> observer) |
protected void |
FlowableElementAtSingle.subscribeActual(SingleObserver<? super T> observer) |
protected void |
FlowableToListSingle.subscribeActual(SingleObserver<? super U> observer) |
protected void |
FlowableCollectSingle.subscribeActual(SingleObserver<? super U> observer) |
Modifier and Type | Method and Description |
---|---|
protected void |
MaybeIsEmptySingle.subscribeActual(SingleObserver<? super Boolean> observer) |
protected void |
MaybeEqualSingle.subscribeActual(SingleObserver<? super Boolean> observer) |
protected void |
MaybeContains.subscribeActual(SingleObserver<? super Boolean> observer) |
protected void |
MaybeCount.subscribeActual(SingleObserver<? super Long> observer) |
protected void |
MaybeMaterialize.subscribeActual(SingleObserver<? super Notification<T>> observer) |
protected void |
MaybeFlatMapSingle.subscribeActual(SingleObserver<? super R> downstream) |
protected void |
MaybeToSingle.subscribeActual(SingleObserver<? super T> observer) |
protected void |
MaybeSwitchIfEmptySingle.subscribeActual(SingleObserver<? super T> observer) |
Modifier and Type | Class and Description |
---|---|
class |
MaterializeSingleObserver<T>
A consumer that implements the consumer types of Maybe, Single and Completable
and turns their signals into Notifications for a SingleObserver.
|
Constructor and Description |
---|
MaterializeSingleObserver(SingleObserver<? super Notification<T>> downstream) |
Modifier and Type | Method and Description |
---|---|
void |
ObservableSequenceEqualSingle.subscribeActual(SingleObserver<? super Boolean> observer) |
protected void |
ObservableAnySingle.subscribeActual(SingleObserver<? super Boolean> t) |
protected void |
ObservableAllSingle.subscribeActual(SingleObserver<? super Boolean> t) |
void |
ObservableCountSingle.subscribeActual(SingleObserver<? super Long> t) |
protected void |
ObservableReduceWithSingle.subscribeActual(SingleObserver<? super R> observer) |
protected void |
ObservableReduceSeedSingle.subscribeActual(SingleObserver<? super R> observer) |
void |
ObservableSingleSingle.subscribeActual(SingleObserver<? super T> t) |
protected void |
ObservableLastSingle.subscribeActual(SingleObserver<? super T> observer) |
void |
ObservableElementAtSingle.subscribeActual(SingleObserver<? super T> t) |
void |
ObservableToListSingle.subscribeActual(SingleObserver<? super U> t) |
protected void |
ObservableCollectSingle.subscribeActual(SingleObserver<? super U> t) |
Modifier and Type | Class and Description |
---|---|
class |
SingleCache<T> |
Modifier and Type | Method and Description |
---|---|
static <T> SingleObserver<T> |
SingleToObservable.create(Observer<? super T> downstream)
Creates a
SingleObserver wrapper around a Observer . |
Modifier and Type | Method and Description |
---|---|
protected void |
SingleEquals.subscribeActual(SingleObserver<? super Boolean> observer) |
protected void |
SingleContains.subscribeActual(SingleObserver<? super Boolean> observer) |
protected void |
SingleTimer.subscribeActual(SingleObserver<? super Long> observer) |
protected void |
SingleMaterialize.subscribeActual(SingleObserver<? super Notification<T>> observer) |
protected void |
SingleNever.subscribeActual(SingleObserver<? super Object> observer) |
protected void |
SingleZipIterable.subscribeActual(SingleObserver<? super R> observer) |
protected void |
SingleZipArray.subscribeActual(SingleObserver<? super R> observer) |
protected void |
SingleMap.subscribeActual(SingleObserver<? super R> t) |
protected void |
SingleLift.subscribeActual(SingleObserver<? super R> observer) |
protected void |
SingleFlatMap.subscribeActual(SingleObserver<? super R> downstream) |
protected void |
SingleUsing.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleUnsubscribeOn.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleTimeout.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleTakeUntil.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleSubscribeOn.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleResumeNext.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleOnErrorReturn.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleObserveOn.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleJust.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleHide.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleFromUnsafeSource.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleFromPublisher.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleFromCallable.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleError.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleDoOnSuccess.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleDoOnSubscribe.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleDoOnEvent.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleDoOnError.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleDoOnDispose.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleDoFinally.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleDoAfterTerminate.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleDoAfterSuccess.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleDetach.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleDelayWithSingle.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleDelayWithPublisher.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleDelayWithObservable.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleDelayWithCompletable.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleDelay.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleDefer.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleCreate.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleCache.subscribeActual(SingleObserver<? super T> observer) |
protected void |
SingleAmb.subscribeActual(SingleObserver<? super T> observer) |
Modifier and Type | Class and Description |
---|---|
class |
EmptyComponent
Singleton implementing many interfaces as empty.
|
Modifier and Type | Class and Description |
---|---|
class |
DisposableSingleObserver<T>
An abstract
SingleObserver that allows asynchronous cancellation by implementing Disposable. |
class |
ResourceSingleObserver<T>
An abstract
SingleObserver that allows asynchronous cancellation of its subscription
and the associated resources. |
class |
TestObserver<T>
An Observer that records events and allows making assertions about them.
|
Modifier and Type | Method and Description |
---|---|
static <T> SingleObserver<? super T> |
RxJavaPlugins.onSubscribe(Single<T> source,
SingleObserver<? super T> observer)
Calls the associated hook function.
|
Modifier and Type | Method and Description |
---|---|
static BiFunction<? super Single,? super SingleObserver,? extends SingleObserver> |
RxJavaPlugins.getOnSingleSubscribe()
Returns the current hook function.
|
static BiFunction<? super Single,? super SingleObserver,? extends SingleObserver> |
RxJavaPlugins.getOnSingleSubscribe()
Returns the current hook function.
|
Modifier and Type | Method and Description |
---|---|
static <T> SingleObserver<? super T> |
RxJavaPlugins.onSubscribe(Single<T> source,
SingleObserver<? super T> observer)
Calls the associated hook function.
|
Modifier and Type | Method and Description |
---|---|
static void |
RxJavaPlugins.setOnSingleSubscribe(BiFunction<? super Single,? super SingleObserver,? extends SingleObserver> onSingleSubscribe)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnSingleSubscribe(BiFunction<? super Single,? super SingleObserver,? extends SingleObserver> onSingleSubscribe)
Sets the specific hook function.
|
Modifier and Type | Class and Description |
---|---|
class |
SingleSubject<T>
Represents a hot Single-like source and consumer of events similar to Subjects.
|
Modifier and Type | Method and Description |
---|---|
protected void |
SingleSubject.subscribeActual(SingleObserver<? super T> observer) |
Copyright © 2019. All rights reserved.