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
CompletableSources 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 intoCompletableSources, subscribes to the newer one while disposing the subscription to the previousCompletableSource, thus keeping at most one activeCompletableSourcerunning.Switch between subsequentCompletableSources emitted by aPublisher.Maps the upstream items intoMaybeSources 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 subsequentMaybeSources emitted by aPublisher.Maps the upstream items intoSingleSources 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 subsequentSingleSources 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 intoCompletableSources 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 intoCompletableSources, subscribes to the newer one while disposing the subscription to the previousCompletableSource, thus keeping at most one activeCompletableSourcerunning.Maps the upstream items intoMaybeSources 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 intoSingleSources 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.