RxJava 3 3.1.8 · io.reactivex.rxjava3.internal.operators.mixed

Class Summary

Modifier and Type	Class and Description
public class	CompletableAndThenObservable< the result type of the ObservableSource and this operator R> After Completable completes, it relays the signals of the ObservableSource to the downstream observer.
public class	CompletableAndThenPublisher< the result type of the Publisher and this operator R> After Completable completes, it relays the signals of the Publisher to the downstream subscriber.
public abstract class	ConcatMapXMainObserver< the upstream value type T> Base class for implementing concatMapX main observers.
public abstract class	ConcatMapXMainSubscriber< the upstream value type T> Base class for implementing concatMapX main subscribers.
public class	FlowableConcatMapCompletable< the upstream value type T> Maps the upstream items into `CompletableSource`s and subscribes to them one after the other completes or terminates (in error-delaying mode).
public class	FlowableConcatMapMaybe< the upstream element type T, the output element type 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.
public class	FlowableConcatMapMaybePublisher< the upstream element type T, the output element type 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.
public class	FlowableConcatMapSingle< the upstream element type T, the output element type 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.
public class	FlowableConcatMapSinglePublisher< the upstream element type T, the output element type 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.
public class	FlowableSwitchMapCompletable< the upstream value type 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.
public class	FlowableSwitchMapCompletablePublisher< the upstream value type T> Switch between subsequent `CompletableSource`s emitted by a `Publisher`.
public class	FlowableSwitchMapMaybe< the upstream value type T, the downstream value type 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.
public class	FlowableSwitchMapMaybePublisher< the upstream value type T, the downstream value type R> Switch between subsequent `MaybeSource`s emitted by a `Publisher`.
public class	FlowableSwitchMapSingle< the upstream value type T, the downstream value type 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.
public class	FlowableSwitchMapSinglePublisher< the upstream value type T, the downstream value type R> Switch between subsequent `SingleSource`s emitted by a `Publisher`.
public class	MaterializeSingleObserver< the element type of the source T> A consumer that implements the consumer types of Maybe, Single and Completable and turns their signals into Notifications for a SingleObserver.
public class	MaybeFlatMapObservable< the success value type of the Maybe source T, the result type of the ObservableSource and this operator R> Maps the success value of a Maybe onto an ObservableSource and relays its signals to the downstream observer.
public class	MaybeFlatMapPublisher< the success value type of the Maybe source T, the result type of the Publisher and this operator R> Maps the success value of a Maybe onto a Publisher and relays its signals to the downstream subscriber.
public class	ObservableConcatMapCompletable< the upstream value type T> Maps the upstream items into `CompletableSource`s and subscribes to them one after the other completes or terminates (in error-delaying mode).
public class	ObservableConcatMapMaybe< the upstream element type T, the output element type 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.
public class	ObservableConcatMapSingle< the upstream element type T, the output element type 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.
public class	ObservableSwitchMapCompletable< the upstream value type 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.
public class	ObservableSwitchMapMaybe< the upstream value type T, the downstream value type 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.
public class	ObservableSwitchMapSingle< the upstream value type T, the downstream value type 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.
pack-priv class	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.
public class	SingleFlatMapObservable< the success value type of the Single source T, the result type of the ObservableSource and this operator R> Maps the success value of a Single onto an ObservableSource and relays its signals to the downstream observer.

Package io.reactivex.rxjava3.internal.operators.mixed

Class Summary