RxJava 3 3.1.8 · io.reactivex.rxjava3.internal.operators.maybe

Class Summary

Modifier and Type	Class and Description
pack-priv abstract class	AbstractMaybeWithUpstream< the source value type T, the output value type R> Abstract base class for intermediate Maybe operators that take an upstream MaybeSource.
public class	MaybeAmb< the value type emitted T> Signals the event of the first MaybeSource that signals.
public class	MaybeCache< the value type T> Consumes the source once and replays its signal to any current or future MaybeObservers.
public class	MaybeCallbackObserver< the value type T> MaybeObserver that delegates the onSuccess, onError and onComplete method calls to callbacks.
public class	MaybeConcatArray< the value type T> Concatenate values of each MaybeSource provided in an array.
public class	MaybeConcatArrayDelayError< the value type T> Concatenate values of each MaybeSource provided in an array and delays any errors till the very end.
public class	MaybeConcatIterable< the value type T> Concatenate values of each MaybeSource provided by an Iterable.
public class	MaybeContains< the value type T> Signals true if the source signals a value that is object-equals with the provided value, false otherwise or for empty sources.
public class	MaybeCount< the source value type T> Signals 1L if the source signalled an item or 0L if the source is empty.
public class	MaybeCreate< the value type emitted T> Provides an API over MaybeObserver that serializes calls to onXXX and manages cancellation in a safe manner.
public class	MaybeDefer< the value type T> Defers the creation of the actual Maybe the incoming MaybeObserver is subscribed to.
public class	MaybeDelay< the value type T> Delays all signal types by the given amount and re-emits them on the given scheduler.
public class	MaybeDelayOtherPublisher< the main value type T, the other value type U> Delay the emission of the main signal until the other signals an item or completes.
public class	MaybeDelaySubscriptionOtherPublisher< the main value type T, the other value type U> Delay the subscription to the main Maybe until the other signals an item or completes.
public class	MaybeDelayWithCompletable<T>
public class	MaybeDematerialize< the element type of the source T, the element type of the Notification and result R> Maps the success value of the source to a Notification, then maps it back to the corresponding signal type.
public class	MaybeDetach< the value type T> Breaks the references between the upstream and downstream when the Maybe terminates.
public class	MaybeDoAfterSuccess< the value type T> Calls a consumer after pushing the current item to the downstream.
public class	MaybeDoFinally< the value type T> Execute an action after an onSuccess, onError, onComplete or a dispose event.
public class	MaybeDoOnEvent< the value type T> Calls a BiConsumer with the success, error values of the upstream Maybe or with two nulls if the Maybe completed.
public class	MaybeDoOnLifecycle< the element type of the flow T> Invokes callbacks upon `onSubscribe` from upstream and `dispose` from downstream.
public class	MaybeDoOnTerminate<T>
public class	MaybeEmpty Signals an onComplete.
public class	MaybeEqualSingle< the common base type of the sources T> Compares two MaybeSources to see if they are both empty or emit the same value compared via a BiPredicate.
public class	MaybeError< the value type T> Signals a constant Throwable.
public class	MaybeErrorCallable< the value type T> Signals a Throwable returned by a Supplier.
public class	MaybeFilter< the upstream value type T> Filters the upstream via a predicate, returning the success item or completing if the predicate returns false.
public class	MaybeFilterSingle< the upstream value type T> Filters the upstream SingleSource via a predicate, returning the success item or completing if the predicate returns false.
public class	MaybeFlatMapBiSelector< the main value type T, the second value type U, the result value type 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.
public class	MaybeFlatMapCompletable< the value type of the source MaybeSource T> Maps the success value of the source MaybeSource into a Completable.
public class	MaybeFlatMapIterableFlowable< the source value type T, the element type of the Iterable R> Maps a success value into an Iterable and streams it back as a Flowable.
public class	MaybeFlatMapIterableObservable< the source value type T, the element type of the Iterable R> Maps a success value into an Iterable and streams it back as a Flowable.
public class	MaybeFlatMapNotification< the source value type T, the result value type R> Maps a value into a MaybeSource and relays its signal.
public class	MaybeFlatMapSingle< the input value type T, the result value type R> Maps the success value of the source MaybeSource into a Single.
public class	MaybeFlatten< the source value type T, the result value type R> Maps a value into a MaybeSource and relays its signal.
public class	MaybeFromAction< the value type T> Executes an Action and signals its exception or completes normally.
public class	MaybeFromCallable< the value type T> Executes a callable and signals its value as success or signals an exception.
public class	MaybeFromCompletable< the value type T> Wrap a Completable into a Maybe.
public class	MaybeFromFuture< the value type T> Waits until the source Future completes or the wait times out; treats a `null` result as indication to signal `onComplete` instead of `onSuccess`.
public class	MaybeFromRunnable< the value type T> Executes an Runnable and signals its exception or completes normally.
public class	MaybeFromSingle< the value type T> Wrap a Single into a Maybe.
public class	MaybeFromSupplier< the value type T> Executes a supplier and signals its value as success or signals an exception.
public class	MaybeHide< the value type T> Hides the identity of the upstream Maybe and its Disposable sent through onSubscribe.
public class	MaybeIgnoreElement< the value type T> Turns an onSuccess into an onComplete, onError and onComplete is relayed as is.
public class	MaybeIgnoreElementCompletable< the value type T> Turns an onSuccess into an onComplete, onError and onComplete is relayed as is.
public class	MaybeIsEmpty< the value type T> Signals true if the source Maybe signals onComplete, signals false if the source Maybe signals onSuccess.
public class	MaybeIsEmptySingle< the value type T> Signals true if the source Maybe signals onComplete, signals false if the source Maybe signals onSuccess.
public class	MaybeJust< the value type T> Signals a constant value.
public class	MaybeLift< the upstream value type T, the downstream value type R> Calls a MaybeOperator for the incoming MaybeObserver.
public class	MaybeMap< the upstream value type T, the downstream value type R> Maps the upstream success value into some other value.
public class	MaybeMaterialize< the element type of the source T> Turn the signal types of a Maybe source into a single Notification of equal kind.
public class	MaybeMergeArray< the value type T> Run all MaybeSources of an array at once and signal their values as they become available.
public class	MaybeNever Doesn't signal any event other than onSubscribe.
public class	MaybeObserveOn< the value type delivered T> Signals the onSuccess, onError or onComplete events on a the specific scheduler.
public class	MaybeOnErrorComplete< the value type T> Emits an onComplete if the source emits an onError and the predicate returns true for that Throwable.
public class	MaybeOnErrorNext< the value type T> Subscribes to the MaybeSource returned by a function if the main source signals an onError.
public class	MaybeOnErrorReturn< the value type T> Returns a value generated via a function if the main source signals an onError.
public class	MaybePeek< the value type T> Peeks into the lifecycle of a Maybe and MaybeObserver.
public class	MaybeSubscribeOn< the value type delivered T> Subscribes to the upstream MaybeSource on the specified scheduler.
public class	MaybeSwitchIfEmpty< the value type T> Subscribes to the other source if the main source is empty.
public class	MaybeSwitchIfEmptySingle< the value type T> Subscribes to the other source if the main source is empty.
public class	MaybeTakeUntilMaybe< the value type T, the other's value type 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.
public class	MaybeTakeUntilPublisher< the value type T, the other's value type 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.
public class	MaybeTimeInterval< the element type of the sequence T> Measures the time between subscription and the success item emission from the upstream and emits this as a `Timed` success value.
public class	MaybeTimeoutMaybe< the main value type T, the other value type U> Switches to the fallback Maybe if the other MaybeSource signals a success or completes, or signals TimeoutException if fallback is null.
public class	MaybeTimeoutPublisher< the main value type T, the other value type U> Switches to the fallback Maybe if the other Publisher signals a success or completes, or signals TimeoutException if fallback is null.
public class	MaybeTimer Signals a `0L` after the specified delay.
public class	MaybeToFlowable< the value type T> Wraps a MaybeSource and exposes it as a Flowable, relaying signals in a backpressure-aware manner and composes cancellation through.
public class	MaybeToObservable< the value type T> Wraps a MaybeSource and exposes it as an Observable, relaying signals in a backpressure-aware manner and composes cancellation through.
public class	MaybeToSingle< the value type T> Wraps a MaybeSource and exposes its onSuccess and onError signals and signals NoSuchElementException for onComplete if `defaultValue` is null.
public class	MaybeUnsafeCreate< the value type T> Wraps a MaybeSource without safeguard and calls its subscribe() method for each MaybeObserver.
public class	MaybeUnsubscribeOn< the value type T> Makes sure a dispose() call from downstream happens on the specified scheduler.
public class	MaybeUsing< the value type T, the resource type 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).
public class	MaybeZipArray<T, R>
public class	MaybeZipIterable<T, R>

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

Class Summary

Enum Summary