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.flowable | |
io.reactivex.internal.operators.maybe | |
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 MaybeObserver<? super T>> |
Maybe.subscribeWith(E observer)
Subscribes a given MaybeObserver (subclass) to this Maybe and returns the given
MaybeObserver as is.
|
Modifier and Type | Method and Description |
---|---|
MaybeObserver<? super Upstream> |
MaybeOperator.apply(MaybeObserver<? super Downstream> observer)
Applies a function to the child MaybeObserver and returns a new parent MaybeObserver.
|
Modifier and Type | Method and Description |
---|---|
MaybeObserver<? super Upstream> |
MaybeOperator.apply(MaybeObserver<? super Downstream> observer)
Applies a function to the child MaybeObserver and returns a new parent MaybeObserver.
|
void |
Maybe.subscribe(MaybeObserver<? super T> observer) |
void |
MaybeSource.subscribe(MaybeObserver<? super T> observer)
Subscribes the given MaybeObserver to this MaybeSource instance.
|
protected abstract void |
Maybe.subscribeActual(MaybeObserver<? super T> observer)
Implement this method in subclasses to handle the incoming
MaybeObserver s. |
Modifier and Type | Method and Description |
---|---|
static void |
EmptyDisposable.complete(MaybeObserver<?> s) |
static void |
EmptyDisposable.error(Throwable e,
MaybeObserver<?> s) |
Modifier and Type | Class and Description |
---|---|
class |
BlockingMultiObserver<T>
A combined Observer that awaits the success or error signal via a CountDownLatch.
|
Modifier and Type | Method and Description |
---|---|
protected void |
FlowableSingleMaybe.subscribeActual(MaybeObserver<? super T> s) |
protected void |
FlowableReduceMaybe.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
FlowableLastMaybe.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
FlowableElementAtMaybe.subscribeActual(MaybeObserver<? super T> s) |
Modifier and Type | Class and Description |
---|---|
class |
MaybeCache<T>
Consumes the source once and replays its signal to any current or future MaybeObservers.
|
class |
MaybeCallbackObserver<T>
MaybeObserver that delegates the onSuccess, onError and onComplete method calls to callbacks.
|
Modifier and Type | Method and Description |
---|---|
static <T> MaybeObserver<T> |
MaybeToObservable.create(Observer<? super T> downstream)
Creates a
MaybeObserver wrapper around a Observer . |
Modifier and Type | Method and Description |
---|---|
protected void |
MaybeIsEmpty.subscribeActual(MaybeObserver<? super Boolean> observer) |
protected void |
MaybeTimer.subscribeActual(MaybeObserver<? super Long> observer) |
protected void |
MaybeEmpty.subscribeActual(MaybeObserver<? super Object> observer) |
protected void |
MaybeNever.subscribeActual(MaybeObserver<? super Object> observer) |
protected void |
MaybeFlatten.subscribeActual(MaybeObserver<? super R> observer) |
protected void |
MaybeFlatMapSingleElement.subscribeActual(MaybeObserver<? super R> actual) |
protected void |
MaybeFlatMapNotification.subscribeActual(MaybeObserver<? super R> observer) |
protected void |
MaybeZipArray.subscribeActual(MaybeObserver<? super R> observer) |
protected void |
MaybeFlatMapBiSelector.subscribeActual(MaybeObserver<? super R> observer) |
protected void |
MaybeLift.subscribeActual(MaybeObserver<? super R> observer) |
protected void |
MaybeMap.subscribeActual(MaybeObserver<? super R> observer) |
protected void |
MaybeZipIterable.subscribeActual(MaybeObserver<? super R> observer) |
protected void |
MaybeDelayWithCompletable.subscribeActual(MaybeObserver<? super T> subscriber) |
protected void |
MaybeCache.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeError.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeDoFinally.subscribeActual(MaybeObserver<? super T> s) |
protected void |
MaybeFromSingle.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeJust.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeAmb.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeTimeoutMaybe.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeDoOnEvent.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeFromCompletable.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeDelayOtherPublisher.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeFromRunnable.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeFilterSingle.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeTakeUntilPublisher.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeIgnoreElement.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeOnErrorReturn.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybePeek.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeDoAfterSuccess.subscribeActual(MaybeObserver<? super T> s) |
protected void |
MaybeErrorCallable.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeDetach.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeObserveOn.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeUsing.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeOnErrorNext.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeTakeUntilMaybe.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeDelay.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeFilter.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeUnsubscribeOn.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeSubscribeOn.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeSwitchIfEmpty.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeOnErrorComplete.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeDelaySubscriptionOtherPublisher.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeUnsafeCreate.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeHide.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeFromAction.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeTimeoutPublisher.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeCreate.subscribeActual(MaybeObserver<? super T> s) |
protected void |
MaybeFromCallable.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeFromFuture.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
MaybeDefer.subscribeActual(MaybeObserver<? super T> observer) |
Modifier and Type | Method and Description |
---|---|
void |
ObservableSingleMaybe.subscribeActual(MaybeObserver<? super T> t) |
protected void |
ObservableReduceMaybe.subscribeActual(MaybeObserver<? super T> observer) |
protected void |
ObservableLastMaybe.subscribeActual(MaybeObserver<? super T> observer) |
void |
ObservableElementAtMaybe.subscribeActual(MaybeObserver<? super T> t) |
Modifier and Type | Method and Description |
---|---|
protected void |
SingleFlatMapMaybe.subscribeActual(MaybeObserver<? super R> actual) |
Modifier and Type | Class and Description |
---|---|
class |
EmptyComponent
Singleton implementing many interfaces as empty.
|
Modifier and Type | Class and Description |
---|---|
class |
DisposableMaybeObserver<T>
An abstract
MaybeObserver that allows asynchronous cancellation by implementing Disposable. |
class |
ResourceMaybeObserver<T>
An abstract
MaybeObserver 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 <T> MaybeObserver<? super T> |
RxJavaPlugins.onSubscribe(Maybe<T> source,
MaybeObserver<? super T> subscriber)
Calls the associated hook function.
|
Modifier and Type | Method and Description |
---|---|
static BiFunction<? super Maybe,? super MaybeObserver,? extends MaybeObserver> |
RxJavaPlugins.getOnMaybeSubscribe()
Returns the current hook function.
|
static BiFunction<? super Maybe,? super MaybeObserver,? extends MaybeObserver> |
RxJavaPlugins.getOnMaybeSubscribe()
Returns the current hook function.
|
Modifier and Type | Method and Description |
---|---|
static <T> MaybeObserver<? super T> |
RxJavaPlugins.onSubscribe(Maybe<T> source,
MaybeObserver<? super T> subscriber)
Calls the associated hook function.
|
Modifier and Type | Method and Description |
---|---|
static void |
RxJavaPlugins.setOnMaybeSubscribe(BiFunction<? super Maybe,MaybeObserver,? extends MaybeObserver> onMaybeSubscribe)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnMaybeSubscribe(BiFunction<? super Maybe,MaybeObserver,? extends MaybeObserver> onMaybeSubscribe)
Sets the specific hook function.
|
Modifier and Type | Class and Description |
---|---|
class |
MaybeSubject<T>
Represents a hot Maybe-like source and consumer of events similar to Subjects.
|
Modifier and Type | Method and Description |
---|---|
protected void |
MaybeSubject.subscribeActual(MaybeObserver<? super T> observer) |
Copyright © 2018 JBoss by Red Hat. All rights reserved.