CompletableAndThenObservable<R> |
After Completable completes, it relays the signals
of the ObservableSource to the downstream observer.
|
CompletableAndThenObservable.AndThenObservableObserver<R> |
|
CompletableAndThenPublisher<R> |
After Completable completes, it relays the signals
of the Publisher to the downstream subscriber.
|
CompletableAndThenPublisher.AndThenPublisherSubscriber<R> |
|
ConcatMapXMainObserver<T> |
Base class for implementing concatMapX main observers.
|
ConcatMapXMainSubscriber<T> |
Base class for implementing concatMapX main subscribers.
|
FlowableConcatMapCompletable<T> |
Maps the upstream items into CompletableSource s and subscribes to them one after the
other completes or terminates (in error-delaying mode).
|
FlowableConcatMapCompletable.ConcatMapCompletableObserver<T> |
|
FlowableConcatMapCompletable.ConcatMapCompletableObserver.ConcatMapInnerObserver |
|
FlowableConcatMapMaybe<T,R> |
Maps each upstream item into a MaybeSource , subscribes to them one after the other terminates
and relays their success values, optionally delaying any errors till the main and inner sources
terminate.
|
FlowableConcatMapMaybe.ConcatMapMaybeSubscriber<T,R> |
|
FlowableConcatMapMaybe.ConcatMapMaybeSubscriber.ConcatMapMaybeObserver<R> |
|
FlowableConcatMapMaybePublisher<T,R> |
Maps each upstream item into a MaybeSource , subscribes to them one after the other terminates
and relays their success values, optionally delaying any errors till the main and inner sources
terminate.
|
FlowableConcatMapSingle<T,R> |
Maps each upstream item into a SingleSource , subscribes to them one after the other terminates
and relays their success values, optionally delaying any errors till the main and inner sources
terminate.
|
FlowableConcatMapSingle.ConcatMapSingleSubscriber<T,R> |
|
FlowableConcatMapSingle.ConcatMapSingleSubscriber.ConcatMapSingleObserver<R> |
|
FlowableConcatMapSinglePublisher<T,R> |
Maps each upstream item into a SingleSource , subscribes to them one after the other terminates
and relays their success values, optionally delaying any errors till the main and inner sources
terminate.
|
FlowableSwitchMapCompletable<T> |
Maps the upstream values into CompletableSource s, subscribes to the newer one while
disposing the subscription to the previous CompletableSource , thus keeping at most one
active CompletableSource running.
|
FlowableSwitchMapCompletable.SwitchMapCompletableObserver<T> |
|
FlowableSwitchMapCompletable.SwitchMapCompletableObserver.SwitchMapInnerObserver |
|
FlowableSwitchMapCompletablePublisher<T> |
|
FlowableSwitchMapMaybe<T,R> |
Maps the upstream items into MaybeSource s and switches (subscribes) to the newer ones
while disposing the older ones and emits the latest success value if available, optionally delaying
errors from the main source or the inner sources.
|
FlowableSwitchMapMaybe.SwitchMapMaybeSubscriber<T,R> |
|
FlowableSwitchMapMaybe.SwitchMapMaybeSubscriber.SwitchMapMaybeObserver<R> |
|
FlowableSwitchMapMaybePublisher<T,R> |
Switch between subsequent MaybeSource s emitted by a Publisher .
|
FlowableSwitchMapSingle<T,R> |
Maps the upstream items into SingleSource s and switches (subscribes) to the newer ones
while disposing the older ones and emits the latest success value, optionally delaying
errors from the main source or the inner sources.
|
FlowableSwitchMapSingle.SwitchMapSingleSubscriber<T,R> |
|
FlowableSwitchMapSingle.SwitchMapSingleSubscriber.SwitchMapSingleObserver<R> |
|
FlowableSwitchMapSinglePublisher<T,R> |
Switch between subsequent SingleSource s emitted by a Publisher .
|
MaterializeSingleObserver<T> |
A consumer that implements the consumer types of Maybe, Single and Completable
and turns their signals into Notifications for a SingleObserver.
|
MaybeFlatMapObservable<T,R> |
Maps the success value of a Maybe onto an ObservableSource and
relays its signals to the downstream observer.
|
MaybeFlatMapObservable.FlatMapObserver<T,R> |
|
MaybeFlatMapPublisher<T,R> |
Maps the success value of a Maybe onto a Publisher and
relays its signals to the downstream subscriber.
|
MaybeFlatMapPublisher.FlatMapPublisherSubscriber<T,R> |
|
ObservableConcatMapCompletable<T> |
Maps the upstream items into CompletableSource s and subscribes to them one after the
other completes or terminates (in error-delaying mode).
|
ObservableConcatMapCompletable.ConcatMapCompletableObserver<T> |
|
ObservableConcatMapCompletable.ConcatMapCompletableObserver.ConcatMapInnerObserver |
|
ObservableConcatMapMaybe<T,R> |
Maps each upstream item into a MaybeSource , subscribes to them one after the other terminates
and relays their success values, optionally delaying any errors till the main and inner sources
terminate.
|
ObservableConcatMapMaybe.ConcatMapMaybeMainObserver<T,R> |
|
ObservableConcatMapMaybe.ConcatMapMaybeMainObserver.ConcatMapMaybeObserver<R> |
|
ObservableConcatMapSingle<T,R> |
Maps each upstream item into a SingleSource , subscribes to them one after the other terminates
and relays their success values, optionally delaying any errors till the main and inner sources
terminate.
|
ObservableConcatMapSingle.ConcatMapSingleMainObserver<T,R> |
|
ObservableConcatMapSingle.ConcatMapSingleMainObserver.ConcatMapSingleObserver<R> |
|
ObservableSwitchMapCompletable<T> |
Maps the upstream values into CompletableSource s, subscribes to the newer one while
disposing the subscription to the previous CompletableSource , thus keeping at most one
active CompletableSource running.
|
ObservableSwitchMapCompletable.SwitchMapCompletableObserver<T> |
|
ObservableSwitchMapCompletable.SwitchMapCompletableObserver.SwitchMapInnerObserver |
|
ObservableSwitchMapMaybe<T,R> |
Maps the upstream items into MaybeSource s and switches (subscribes) to the newer ones
while disposing the older ones and emits the latest success value if available, optionally delaying
errors from the main source or the inner sources.
|
ObservableSwitchMapMaybe.SwitchMapMaybeMainObserver<T,R> |
|
ObservableSwitchMapMaybe.SwitchMapMaybeMainObserver.SwitchMapMaybeObserver<R> |
|
ObservableSwitchMapSingle<T,R> |
Maps the upstream items into SingleSource s and switches (subscribes) to the newer ones
while disposing the older ones and emits the latest success value if available, optionally delaying
errors from the main source or the inner sources.
|
ObservableSwitchMapSingle.SwitchMapSingleMainObserver<T,R> |
|
ObservableSwitchMapSingle.SwitchMapSingleMainObserver.SwitchMapSingleObserver<R> |
|
ScalarXMapZHelper |
Utility class to extract a value from a scalar source reactive type,
map it to a 0-1 type then subscribe the output type's consumer to it,
saving on the overhead of the regular subscription channel.
|
SingleFlatMapObservable<T,R> |
Maps the success value of a Single onto an ObservableSource and
relays its signals to the downstream observer.
|
SingleFlatMapObservable.FlatMapObserver<T,R> |
|