class |
MaybeDelay<T> |
Delays all signal types by the given amount and re-emits them on the given scheduler.
|
class |
MaybeDelayOtherPublisher<T,U> |
Delay the emission of the main signal until the other signals an item or completes.
|
class |
MaybeDelaySubscriptionOtherPublisher<T,U> |
Delay the subscription to the main Maybe until the other signals an item or completes.
|
class |
MaybeDematerialize<T,R> |
Maps the success value of the source to a Notification, then
maps it back to the corresponding signal type.
|
class |
MaybeDetach<T> |
Breaks the references between the upstream and downstream when the Maybe terminates.
|
class |
MaybeDoAfterSuccess<T> |
Calls a consumer after pushing the current item to the downstream.
|
class |
MaybeDoFinally<T> |
Execute an action after an onSuccess, onError, onComplete or a dispose event.
|
class |
MaybeDoOnEvent<T> |
Calls a BiConsumer with the success, error values of the upstream Maybe or with two nulls if
the Maybe completed.
|
class |
MaybeDoOnLifecycle<T> |
Invokes callbacks upon onSubscribe from upstream and
dispose from downstream.
|
class |
MaybeFilter<T> |
Filters the upstream via a predicate, returning the success item or completing if
the predicate returns false.
|
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.
|
class |
MaybeFlatMapNotification<T,R> |
Maps a value into a MaybeSource and relays its signal.
|
class |
MaybeFlatten<T,R> |
Maps a value into a MaybeSource and relays its signal.
|
class |
MaybeHide<T> |
Hides the identity of the upstream Maybe and its Disposable sent through onSubscribe.
|
class |
MaybeIgnoreElement<T> |
Turns an onSuccess into an onComplete, onError and onComplete is relayed as is.
|
class |
MaybeIsEmpty<T> |
Signals true if the source Maybe signals onComplete, signals false if the source Maybe
signals onSuccess.
|
class |
MaybeLift<T,R> |
Calls a MaybeOperator for the incoming MaybeObserver.
|
class |
MaybeMap<T,R> |
Maps the upstream success value into some other value.
|
class |
MaybeObserveOn<T> |
Signals the onSuccess, onError or onComplete events on a the specific scheduler.
|
class |
MaybeOnErrorComplete<T> |
Emits an onComplete if the source emits an onError and the predicate returns true for
that Throwable.
|
class |
MaybeOnErrorNext<T> |
Subscribes to the MaybeSource returned by a function if the main source signals an onError.
|
class |
MaybeOnErrorReturn<T> |
Returns a value generated via a function if the main source signals an onError.
|
class |
MaybePeek<T> |
Peeks into the lifecycle of a Maybe and MaybeObserver.
|
class |
MaybeSubscribeOn<T> |
Subscribes to the upstream MaybeSource on the specified scheduler.
|
class |
MaybeSwitchIfEmpty<T> |
Subscribes to the other source if the main source is empty.
|
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.
|
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.
|
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.
|
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.
|
class |
MaybeUnsafeCreate<T> |
Wraps a MaybeSource without safeguard and calls its subscribe() method for each MaybeObserver.
|
class |
MaybeUnsubscribeOn<T> |
Makes sure a dispose() call from downstream happens on the specified scheduler.
|