Package io.reactivex.rxjava3.internal.operators.maybe
package io.reactivex.rxjava3.internal.operators.maybe
-
ClassDescriptionAbstract base class for intermediate Maybe operators that take an upstream MaybeSource.MaybeAmb<T>Signals the event of the first MaybeSource that signals.MaybeCache<T>Consumes the source once and replays its signal to any current or future MaybeObservers.MaybeObserver that delegates the onSuccess, onError and onComplete method calls to callbacks.Concatenate values of each MaybeSource provided in an array.Concatenate values of each MaybeSource provided in an array and delays any errors till the very end.Concatenate values of each MaybeSource provided by an Iterable.Signals true if the source signals a value that is object-equals with the provided value, false otherwise or for empty sources.MaybeCount<T>Signals 1L if the source signalled an item or 0L if the source is empty.MaybeCreate<T>Provides an API over MaybeObserver that serializes calls to onXXX and manages cancellation in a safe manner.MaybeDefer<T>Defers the creation of the actual Maybe the incoming MaybeObserver is subscribed to.MaybeDelay<T>Delays all signal types by the given amount and re-emits them on the given scheduler.Delay the emission of the main signal until the other signals an item or completes.Delay the subscription to the main Maybe until the other signals an item or completes.MaybeDematerialize<T,
R> Maps the success value of the source to a Notification, then maps it back to the corresponding signal type.MaybeDetach<T>Breaks the references between the upstream and downstream when the Maybe terminates.Calls a consumer after pushing the current item to the downstream.Execute an action after an onSuccess, onError, onComplete or a dispose event.Calls a BiConsumer with the success, error values of the upstream Maybe or with two nulls if the Maybe completed.Invokes callbacks upononSubscribe
from upstream anddispose
from downstream.Signals an onComplete.Compares two MaybeSources to see if they are both empty or emit the same value compared via a BiPredicate.MaybeError<T>Signals a constant Throwable.Signals a Throwable returned by a Supplier.MaybeFilter<T>Filters the upstream via a predicate, returning the success item or completing if the predicate returns false.Filters the upstream SingleSource via a predicate, returning the success item or completing if the predicate returns false.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.Maps the success value of the source MaybeSource into a Completable.Maps a success value into an Iterable and streams it back as a Flowable.Maps a success value into an Iterable and streams it back as a Flowable.Maps a value into a MaybeSource and relays its signal.MaybeFlatMapSingle<T,R> Maps the success value of the source MaybeSource into a Single.MaybeFlatten<T,R> Maps a value into a MaybeSource and relays its signal.Executes an Action and signals its exception or completes normally.Executes a callable and signals its value as success or signals an exception.Wrap a Completable into a Maybe.Waits until the source Future completes or the wait times out; treats anull
result as indication to signalonComplete
instead ofonSuccess
.Executes an Runnable and signals its exception or completes normally.Wrap a Single into a Maybe.Executes a supplier and signals its value as success or signals an exception.MaybeHide<T>Hides the identity of the upstream Maybe and its Disposable sent through onSubscribe.Turns an onSuccess into an onComplete, onError and onComplete is relayed as is.Turns an onSuccess into an onComplete, onError and onComplete is relayed as is.MaybeIsEmpty<T>Signals true if the source Maybe signals onComplete, signals false if the source Maybe signals onSuccess.Signals true if the source Maybe signals onComplete, signals false if the source Maybe signals onSuccess.MaybeJust<T>Signals a constant value.MaybeLift<T,R> Calls a MaybeOperator for the incoming MaybeObserver.MaybeMap<T,R> Maps the upstream success value into some other value.Turn the signal types of a Maybe source into a single Notification of equal kind.Run all MaybeSources of an array at once and signal their values as they become available.Doesn't signal any event other than onSubscribe.Signals the onSuccess, onError or onComplete events on a the specific scheduler.Emits an onComplete if the source emits an onError and the predicate returns true for that Throwable.Subscribes to the MaybeSource returned by a function if the main source signals an onError.Returns a value generated via a function if the main source signals an onError.MaybePeek<T>Peeks into the lifecycle of a Maybe and MaybeObserver.Subscribes to the upstream MaybeSource on the specified scheduler.Subscribes to the other source if the main source is empty.Subscribes to the other source if the main source is empty.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.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.Measures the time between subscription and the success item emission from the upstream and emits this as aTimed
success value.MaybeTimeoutMaybe<T,U> Switches to the fallback Maybe if the other MaybeSource signals a success or completes, or signals TimeoutException if fallback is null.Switches to the fallback Maybe if the other Publisher signals a success or completes, or signals TimeoutException if fallback is null.Signals a0L
after the specified delay.Wraps a MaybeSource and exposes it as a Flowable, relaying signals in a backpressure-aware manner and composes cancellation through.Wraps a MaybeSource and exposes it as an Observable, relaying signals in a backpressure-aware manner and composes cancellation through.Helper function to merge/concat values of each MaybeSource provided by a Publisher.Wraps a MaybeSource and exposes its onSuccess and onError signals and signals NoSuchElementException for onComplete ifdefaultValue
is null.Wraps a MaybeSource without safeguard and calls its subscribe() method for each MaybeObserver.Makes sure a dispose() call from downstream happens on the specified scheduler.MaybeUsing<T,D> Creates a resource and a dependent Maybe for each incoming Observer and optionally disposes the resource eagerly (before the terminal event is send out).MaybeZipArray<T,R> MaybeZipIterable<T,R>