Uses of Class
io.reactivex.rxjava3.internal.operators.maybe.AbstractMaybeWithUpstream
Packages that use AbstractMaybeWithUpstream
-
Uses of AbstractMaybeWithUpstream in io.reactivex.rxjava3.internal.operators.maybe
Subclasses of AbstractMaybeWithUpstream in io.reactivex.rxjava3.internal.operators.maybeModifier and TypeClassDescriptionfinal class
MaybeDelay<T>
Delays all signal types by the given amount and re-emits them on the given scheduler.final class
Delay the emission of the main signal until the other signals an item or completes.final class
Delay the subscription to the main Maybe until the other signals an item or completes.final class
MaybeDematerialize<T,
R> Maps the success value of the source to a Notification, then maps it back to the corresponding signal type.final class
MaybeDetach<T>
Breaks the references between the upstream and downstream when the Maybe terminates.final class
Calls a consumer after pushing the current item to the downstream.final class
Execute an action after an onSuccess, onError, onComplete or a dispose event.final class
Calls a BiConsumer with the success, error values of the upstream Maybe or with two nulls if the Maybe completed.final class
Invokes callbacks upononSubscribe
from upstream anddispose
from downstream.final class
MaybeFilter<T>
Filters the upstream via a predicate, returning the success item or completing if the predicate returns false.final class
MaybeFlatMapBiSelector<T,
U, R> Maps a source item to another MaybeSource then calls a BiFunction with the original item and the secondary item to generate the final result.final class
Maps a value into a MaybeSource and relays its signal.final class
MaybeFlatten<T,
R> Maps a value into a MaybeSource and relays its signal.final class
MaybeHide<T>
Hides the identity of the upstream Maybe and its Disposable sent through onSubscribe.final class
Turns an onSuccess into an onComplete, onError and onComplete is relayed as is.final class
MaybeIsEmpty<T>
Signals true if the source Maybe signals onComplete, signals false if the source Maybe signals onSuccess.final class
MaybeLift<T,
R> Calls a MaybeOperator for the incoming MaybeObserver.final class
MaybeMap<T,
R> Maps the upstream success value into some other value.final class
Signals the onSuccess, onError or onComplete events on a the specific scheduler.final class
Emits an onComplete if the source emits an onError and the predicate returns true for that Throwable.final class
Subscribes to the MaybeSource returned by a function if the main source signals an onError.final class
Returns a value generated via a function if the main source signals an onError.final class
MaybePeek<T>
Peeks into the lifecycle of a Maybe and MaybeObserver.final class
Subscribes to the upstream MaybeSource on the specified scheduler.final class
Subscribes to the other source if the main source is empty.final class
MaybeTakeUntilMaybe<T,
U> Relays the main source's event unless the other Maybe signals an item first or just completes at which point the resulting Maybe is completed.final class
Relays the main source's event unless the other Publisher signals an item first or just completes at which point the resulting Maybe is completed.final class
MaybeTimeoutMaybe<T,
U> Switches to the fallback Maybe if the other MaybeSource signals a success or completes, or signals TimeoutException if fallback is null.final class
Switches to the fallback Maybe if the other Publisher signals a success or completes, or signals TimeoutException if fallback is null.final class
Wraps a MaybeSource without safeguard and calls its subscribe() method for each MaybeObserver.final class
Makes sure a dispose() call from downstream happens on the specified scheduler.