Uses of Interface
io.reactivex.rxjava3.internal.fuseable.HasUpstreamMaybeSource

Packages that use HasUpstreamMaybeSource

Package	Description
io.reactivex.rxjava3.internal.operators.maybe

Uses of HasUpstreamMaybeSource in io.reactivex.rxjava3.internal.operators.maybe

Classes in io.reactivex.rxjava3.internal.operators.maybe that implement HasUpstreamMaybeSource

Modifier and Type	Class	Description
(package private) class	AbstractMaybeWithUpstream<T,R>	Abstract base class for intermediate Maybe operators that take an upstream MaybeSource.
final class	MaybeContains<T>	Signals true if the source signals a value that is object-equals with the provided value, false otherwise or for empty sources.
final class	MaybeCount<T>	Signals 1L if the source signalled an item or 0L if the source is empty.
final class	MaybeDelay<T>	Delays all signal types by the given amount and re-emits them on the given scheduler.
final class	MaybeDelayOtherPublisher<T,U>	Delay the emission of the main signal until the other signals an item or completes.
final class	MaybeDelaySubscriptionOtherPublisher<T,U>	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	MaybeDoAfterSuccess<T>	Calls a consumer after pushing the current item to the downstream.
final class	MaybeDoFinally<T>	Execute an action after an onSuccess, onError, onComplete or a dispose event.
final class	MaybeDoOnEvent<T>	Calls a BiConsumer with the success, error values of the upstream Maybe or with two nulls if the Maybe completed.
final class	MaybeDoOnLifecycle<T>	Invokes callbacks upon onSubscribe from upstream and dispose 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	MaybeFlatMapNotification<T,R>	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	MaybeIgnoreElement<T>	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	MaybeIsEmptySingle<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	MaybeObserveOn<T>	Signals the onSuccess, onError or onComplete events on a the specific scheduler.
final class	MaybeOnErrorComplete<T>	Emits an onComplete if the source emits an onError and the predicate returns true for that Throwable.
final class	MaybeOnErrorNext<T>	Subscribes to the MaybeSource returned by a function if the main source signals an onError.
final class	MaybeOnErrorReturn<T>	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	MaybeSubscribeOn<T>	Subscribes to the upstream MaybeSource on the specified scheduler.
final class	MaybeSwitchIfEmpty<T>	Subscribes to the other source if the main source is empty.
final class	MaybeSwitchIfEmptySingle<T>	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	MaybeTakeUntilPublisher<T,U>	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	MaybeTimeoutPublisher<T,U>	Switches to the fallback Maybe if the other Publisher signals a success or completes, or signals TimeoutException if fallback is null.
final class	MaybeToFlowable<T>	Wraps a MaybeSource and exposes it as a Flowable, relaying signals in a backpressure-aware manner and composes cancellation through.
final class	MaybeToObservable<T>	Wraps a MaybeSource and exposes it as an Observable, relaying signals in a backpressure-aware manner and composes cancellation through.
final class	MaybeToSingle<T>	Wraps a MaybeSource and exposes its onSuccess and onError signals and signals NoSuchElementException for onComplete if defaultValue is null.
final class	MaybeUnsafeCreate<T>	Wraps a MaybeSource without safeguard and calls its subscribe() method for each MaybeObserver.
final class	MaybeUnsubscribeOn<T>	Makes sure a dispose() call from downstream happens on the specified scheduler.