Package io.reactivex.rxjava3.internal.operators.mixed
package io.reactivex.rxjava3.internal.operators.mixed
-
ClassesClassDescriptionAfter Completable completes, it relays the signals of the ObservableSource to the downstream observer.After Completable completes, it relays the signals of the Publisher to the downstream subscriber.Base class for implementing concatMapX main observers.Base class for implementing concatMapX main subscribers.Maps the upstream items into
CompletableSource
s and subscribes to them one after the other completes or terminates (in error-delaying mode).Maps each upstream item into aMaybeSource
, subscribes to them one after the other terminates and relays their success values, optionally delaying any errors till the main and inner sources terminate.Maps each upstream item into aMaybeSource
, subscribes to them one after the other terminates and relays their success values, optionally delaying any errors till the main and inner sources terminate.Maps each upstream item into aSingleSource
, subscribes to them one after the other terminates and relays their success values, optionally delaying any errors till the main and inner sources terminate.Maps each upstream item into aSingleSource
, subscribes to them one after the other terminates and relays their success values, optionally delaying any errors till the main and inner sources terminate.Maps the upstream values intoCompletableSource
s, subscribes to the newer one while disposing the subscription to the previousCompletableSource
, thus keeping at most one activeCompletableSource
running.Switch between subsequentCompletableSource
s emitted by aPublisher
.Maps the upstream items intoMaybeSource
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.Switch between subsequentMaybeSource
s emitted by aPublisher
.Maps the upstream items intoSingleSource
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.Switch between subsequentSingleSource
s emitted by aPublisher
.A consumer that implements the consumer types of Maybe, Single and Completable and turns their signals into Notifications for a SingleObserver.Maps the success value of a Maybe onto an ObservableSource and relays its signals to the downstream observer.Maps the success value of a Maybe onto a Publisher and relays its signals to the downstream subscriber.Maps the upstream items intoCompletableSource
s and subscribes to them one after the other completes or terminates (in error-delaying mode).Maps each upstream item into aMaybeSource
, subscribes to them one after the other terminates and relays their success values, optionally delaying any errors till the main and inner sources terminate.Maps each upstream item into aSingleSource
, subscribes to them one after the other terminates and relays their success values, optionally delaying any errors till the main and inner sources terminate.Maps the upstream values intoCompletableSource
s, subscribes to the newer one while disposing the subscription to the previousCompletableSource
, thus keeping at most one activeCompletableSource
running.Maps the upstream items intoMaybeSource
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.Maps the upstream items intoSingleSource
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.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.Maps the success value of a Single onto an ObservableSource and relays its signals to the downstream observer.