Package | Description |
---|---|
io.reactivex.internal.operators.maybe |
Modifier and Type | Class and Description |
---|---|
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.
|
class |
MaybeCount<T>
Signals 1L if the source signalled an item or 0L if the source is empty.
|
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 |
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 |
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 |
MaybeIsEmptySingle<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 |
MaybeSwitchIfEmptySingle<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 |
MaybeToFlowable<T>
Wraps a MaybeSource and exposes it as a Flowable, relaying signals in a backpressure-aware manner
and composes cancellation through.
|
class |
MaybeToObservable<T>
Wraps a MaybeSource and exposes it as an Observable, relaying signals in a backpressure-aware manner
and composes cancellation through.
|
class |
MaybeToSingle<T>
Wraps a MaybeSource and exposes its onSuccess and onError signals and signals
NoSuchElementException for onComplete.
|
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.
|
Copyright © 2019. All rights reserved.