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

package io.reactivex.rxjava3.internal.operators.mixed
  • Classes
    Class
    Description
    CompletableAndThenObservable<R>
    After Completable completes, it relays the signals of the ObservableSource to the downstream observer.
    CompletableAndThenPublisher<R>
    After Completable completes, it relays the signals of the Publisher to the downstream subscriber.
    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 CompletableSources and subscribes to them one after the other completes or terminates (in error-delaying mode).
    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.
    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.
    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 CompletableSources, subscribes to the newer one while disposing the subscription to the previous CompletableSource, thus keeping at most one active CompletableSource running.
    FlowableSwitchMapCompletablePublisher<T>
    Switch between subsequent CompletableSources emitted by a Publisher.
    FlowableSwitchMapMaybe<T,R>
    Maps the upstream items into MaybeSources 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.
    FlowableSwitchMapMaybePublisher<T,R>
    Switch between subsequent MaybeSources emitted by a Publisher.
    FlowableSwitchMapSingle<T,R>
    Maps the upstream items into SingleSources 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.
    FlowableSwitchMapSinglePublisher<T,R>
    Switch between subsequent SingleSources 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.
    MaybeFlatMapPublisher<T,R>
    Maps the success value of a Maybe onto a Publisher and relays its signals to the downstream subscriber.
    ObservableConcatMapCompletable<T>
    Maps the upstream items into CompletableSources and subscribes to them one after the other completes or terminates (in error-delaying mode).
    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.
    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.
    ObservableSwitchMapCompletable<T>
    Maps the upstream values into CompletableSources, subscribes to the newer one while disposing the subscription to the previous CompletableSource, thus keeping at most one active CompletableSource running.
    ObservableSwitchMapMaybe<T,R>
    Maps the upstream items into MaybeSources 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<T,R>
    Maps the upstream items into SingleSources 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.
    SingleFlatMapObservable<T,R>
    Maps the success value of a Single onto an ObservableSource and relays its signals to the downstream observer.