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 CompletableObserver> |
Completable.subscribeWith(E observer)
Subscribes a given CompletableObserver (subclass) to this Completable and returns the given
CompletableObserver as is.
|
Modifier and Type | Method and Description |
---|---|
CompletableObserver |
CompletableOperator.apply(CompletableObserver observer)
Applies a function to the child CompletableObserver and returns a new parent CompletableObserver.
|
Modifier and Type | Method and Description |
---|---|
CompletableObserver |
CompletableOperator.apply(CompletableObserver observer)
Applies a function to the child CompletableObserver and returns a new parent CompletableObserver.
|
void |
Completable.subscribe(CompletableObserver s) |
void |
CompletableSource.subscribe(CompletableObserver cs)
Subscribes the given CompletableObserver to this CompletableSource instance.
|
protected abstract void |
Completable.subscribeActual(CompletableObserver s)
Implement this method to handle the incoming
CompletableObserver s and
perform the business logic in your operator. |
Modifier and Type | Method and Description |
---|---|
static void |
EmptyDisposable.complete(CompletableObserver s) |
static void |
EmptyDisposable.error(Throwable e,
CompletableObserver s) |
Modifier and Type | Class and Description |
---|---|
class |
BlockingMultiObserver<T>
A combined Observer that awaits the success or error signal via a CountDownLatch.
|
class |
CallbackCompletableObserver |
class |
EmptyCompletableObserver |
class |
SubscriberCompletableObserver<T> |
Modifier and Type | Class and Description |
---|---|
class |
CompletableCache
Consume the upstream source exactly once and cache its terminal event.
|
Modifier and Type | Method and Description |
---|---|
protected void |
CompletableDoOnEvent.subscribeActual(CompletableObserver s) |
protected void |
CompletableUsing.subscribeActual(CompletableObserver observer) |
void |
CompletableConcat.subscribeActual(CompletableObserver s) |
protected void |
CompletableObserveOn.subscribeActual(CompletableObserver s) |
protected void |
CompletableCreate.subscribeActual(CompletableObserver s) |
void |
CompletableEmpty.subscribeActual(CompletableObserver s) |
protected void |
CompletableFromSingle.subscribeActual(CompletableObserver s) |
protected void |
CompletableFromCallable.subscribeActual(CompletableObserver s) |
void |
CompletableMergeArray.subscribeActual(CompletableObserver s) |
void |
CompletableTimeout.subscribeActual(CompletableObserver s) |
void |
CompletableMerge.subscribeActual(CompletableObserver s) |
protected void |
CompletableLift.subscribeActual(CompletableObserver s) |
protected void |
CompletableDisposeOn.subscribeActual(CompletableObserver s) |
protected void |
CompletableFromObservable.subscribeActual(CompletableObserver s) |
protected void |
CompletableHide.subscribeActual(CompletableObserver observer) |
protected void |
CompletableDefer.subscribeActual(CompletableObserver s) |
protected void |
CompletableResumeNext.subscribeActual(CompletableObserver s) |
void |
CompletableMergeIterable.subscribeActual(CompletableObserver s) |
protected void |
CompletableNever.subscribeActual(CompletableObserver s) |
protected void |
CompletableDelay.subscribeActual(CompletableObserver s) |
protected void |
CompletableDoFinally.subscribeActual(CompletableObserver s) |
protected void |
CompletableSubscribeOn.subscribeActual(CompletableObserver s) |
protected void |
CompletableDetach.subscribeActual(CompletableObserver observer) |
protected void |
CompletableOnErrorComplete.subscribeActual(CompletableObserver s) |
protected void |
CompletableError.subscribeActual(CompletableObserver s) |
void |
CompletableAmb.subscribeActual(CompletableObserver s) |
void |
CompletableMergeDelayErrorIterable.subscribeActual(CompletableObserver s) |
protected void |
CompletableTimer.subscribeActual(CompletableObserver s) |
protected void |
CompletableFromRunnable.subscribeActual(CompletableObserver s) |
void |
CompletableConcatIterable.subscribeActual(CompletableObserver s) |
protected void |
CompletableFromPublisher.subscribeActual(CompletableObserver cs) |
void |
CompletableConcatArray.subscribeActual(CompletableObserver s) |
protected void |
CompletableFromAction.subscribeActual(CompletableObserver s) |
protected void |
CompletablePeek.subscribeActual(CompletableObserver s) |
protected void |
CompletableErrorSupplier.subscribeActual(CompletableObserver s) |
void |
CompletableMergeDelayErrorArray.subscribeActual(CompletableObserver s) |
protected void |
CompletableCache.subscribeActual(CompletableObserver s) |
protected void |
CompletableFromUnsafeSource.subscribeActual(CompletableObserver observer) |
Modifier and Type | Method and Description |
---|---|
protected void |
FlowableIgnoreElementsCompletable.subscribeActual(CompletableObserver t) |
protected void |
FlowableFlatMapCompletableCompletable.subscribeActual(CompletableObserver observer) |
Modifier and Type | Method and Description |
---|---|
protected void |
MaybeIgnoreElementCompletable.subscribeActual(CompletableObserver observer) |
protected void |
MaybeFlatMapCompletable.subscribeActual(CompletableObserver s) |
Modifier and Type | Method and Description |
---|---|
protected void |
ObservableConcatMapCompletable.subscribeActual(CompletableObserver s) |
protected void |
ObservableSwitchMapCompletable.subscribeActual(CompletableObserver s) |
protected void |
FlowableConcatMapCompletable.subscribeActual(CompletableObserver s) |
protected void |
FlowableSwitchMapCompletable.subscribeActual(CompletableObserver s) |
Modifier and Type | Method and Description |
---|---|
protected void |
ObservableFlatMapCompletableCompletable.subscribeActual(CompletableObserver observer) |
void |
ObservableIgnoreElementsCompletable.subscribeActual(CompletableObserver t) |
Modifier and Type | Method and Description |
---|---|
protected void |
SingleFlatMapCompletable.subscribeActual(CompletableObserver s) |
Modifier and Type | Class and Description |
---|---|
class |
EmptyComponent
Singleton implementing many interfaces as empty.
|
Modifier and Type | Class and Description |
---|---|
class |
DisposableCompletableObserver
An abstract
CompletableObserver that allows asynchronous cancellation by implementing Disposable. |
class |
ResourceCompletableObserver
An abstract
CompletableObserver that allows asynchronous cancellation of its subscription and associated resources. |
class |
TestObserver<T>
An Observer that records events and allows making assertions about them.
|
Modifier and Type | Method and Description |
---|---|
static CompletableObserver |
RxJavaPlugins.onSubscribe(Completable source,
CompletableObserver observer)
Calls the associated hook function.
|
Modifier and Type | Method and Description |
---|---|
static BiFunction<? super Completable,? super CompletableObserver,? extends CompletableObserver> |
RxJavaPlugins.getOnCompletableSubscribe()
Returns the current hook function.
|
static BiFunction<? super Completable,? super CompletableObserver,? extends CompletableObserver> |
RxJavaPlugins.getOnCompletableSubscribe()
Returns the current hook function.
|
Modifier and Type | Method and Description |
---|---|
static CompletableObserver |
RxJavaPlugins.onSubscribe(Completable source,
CompletableObserver observer)
Calls the associated hook function.
|
Modifier and Type | Method and Description |
---|---|
static void |
RxJavaPlugins.setOnCompletableSubscribe(BiFunction<? super Completable,? super CompletableObserver,? extends CompletableObserver> onCompletableSubscribe)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnCompletableSubscribe(BiFunction<? super Completable,? super CompletableObserver,? extends CompletableObserver> onCompletableSubscribe)
Sets the specific hook function.
|
Modifier and Type | Class and Description |
---|---|
class |
CompletableSubject
Represents a hot Completable-like source and consumer of events similar to Subjects.
|
Modifier and Type | Method and Description |
---|---|
protected void |
CompletableSubject.subscribeActual(CompletableObserver observer) |
Copyright © 2018 JBoss by Red Hat. All rights reserved.