Class | Description |
---|---|
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.
|
MaybeCallbackObserver<T> |
MaybeObserver that delegates the onSuccess, onError and onComplete method calls to callbacks.
|
MaybeConcatArray<T> |
Concatenate values of each MaybeSource provided in an array.
|
MaybeConcatArrayDelayError<T> |
Concatenate values of each MaybeSource provided in an array and delays
any errors till the very end.
|
MaybeConcatIterable<T> |
Concatenate values of each MaybeSource provided by an Iterable.
|
MaybeContains<T> |
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.
|
MaybeDelayOtherPublisher<T,U> |
Delay the emission of the main signal until the other signals an item or completes.
|
MaybeDelaySubscriptionOtherPublisher<T,U> |
Delay the subscription to the main Maybe until the other signals an item or completes.
|
MaybeDelayWithCompletable<T> | |
MaybeDetach<T> |
Breaks the references between the upstream and downstream when the Maybe terminates.
|
MaybeDoAfterSuccess<T> |
Calls a consumer after pushing the current item to the downstream.
|
MaybeDoFinally<T> |
Execute an action after an onSuccess, onError, onComplete or a dispose event.
|
MaybeDoOnEvent<T> |
Calls a BiConsumer with the success, error values of the upstream Maybe or with two nulls if
the Maybe completed.
|
MaybeEmpty |
Signals an onComplete.
|
MaybeEqualSingle<T> |
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.
|
MaybeErrorCallable<T> |
Signals a Throwable returned by a Callable.
|
MaybeFilter<T> |
Filters the upstream via a predicate, returning the success item or completing if
the predicate returns false.
|
MaybeFilterSingle<T> |
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.
|
MaybeFlatMapCompletable<T> |
Maps the success value of the source MaybeSource into a Completable.
|
MaybeFlatMapIterableFlowable<T,R> |
Maps a success value into an Iterable and streams it back as a Flowable.
|
MaybeFlatMapIterableObservable<T,R> |
Maps a success value into an Iterable and streams it back as a Flowable.
|
MaybeFlatMapNotification<T,R> |
Maps a value into a MaybeSource and relays its signal.
|
MaybeFlatMapSingle<T,R> |
Maps the success value of the source MaybeSource into a Single.
|
MaybeFlatMapSingleElement<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.
|
MaybeFromAction<T> |
Executes an Action and signals its exception or completes normally.
|
MaybeFromCallable<T> |
Executes a callable and signals its value as success or signals an exception.
|
MaybeFromCompletable<T> |
Wrap a Single into a Maybe.
|
MaybeFromFuture<T> |
Waits until the source Future completes or the wait times out; treats a
null
result as indication to signal onComplete instead of onSuccess . |
MaybeFromRunnable<T> |
Executes an Runnable and signals its exception or completes normally.
|
MaybeFromSingle<T> |
Wrap a Single into a Maybe.
|
MaybeHide<T> |
Hides the identity of the upstream Maybe and its Disposable sent through onSubscribe.
|
MaybeIgnoreElement<T> |
Turns an onSuccess into an onComplete, onError and onComplete is relayed as is.
|
MaybeIgnoreElementCompletable<T> |
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.
|
MaybeIsEmptySingle<T> |
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.
|
MaybeMaterialize<T> |
Turn the signal types of a Maybe source into a single Notification of
equal kind.
|
MaybeMergeArray<T> |
Run all MaybeSources of an array at once and signal their values as they become available.
|
MaybeNever |
Doesn't signal any event other than onSubscribe.
|
MaybeObserveOn<T> |
Signals the onSuccess, onError or onComplete events on a the specific scheduler.
|
MaybeOnErrorComplete<T> |
Emits an onComplete if the source emits an onError and the predicate returns true for
that Throwable.
|
MaybeOnErrorNext<T> |
Subscribes to the MaybeSource returned by a function if the main source signals an onError.
|
MaybeOnErrorReturn<T> |
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.
|
MaybeSubscribeOn<T> |
Subscribes to the upstream MaybeSource on the specified scheduler.
|
MaybeSwitchIfEmpty<T> |
Subscribes to the other source if the main source is empty.
|
MaybeSwitchIfEmptySingle<T> |
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.
|
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.
|
MaybeTimeoutMaybe<T,U> |
Switches to the fallback Maybe if the other MaybeSource signals a success or completes, or
signals TimeoutException if fallback is null.
|
MaybeTimeoutPublisher<T,U> |
Switches to the fallback Maybe if the other Publisher signals a success or completes, or
signals TimeoutException if fallback is null.
|
MaybeTimer |
Signals a
0L after the specified delay. |
MaybeToFlowable<T> |
Wraps a MaybeSource and exposes it as a Flowable, relaying signals in a backpressure-aware manner
and composes cancellation through.
|
MaybeToObservable<T> |
Wraps a MaybeSource and exposes it as an Observable, relaying signals in a backpressure-aware manner
and composes cancellation through.
|
MaybeToSingle<T> |
Wraps a MaybeSource and exposes its onSuccess and onError signals and signals
NoSuchElementException for onComplete.
|
MaybeUnsafeCreate<T> |
Wraps a MaybeSource without safeguard and calls its subscribe() method for each MaybeObserver.
|
MaybeUnsubscribeOn<T> |
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> |
Enum | Description |
---|---|
MaybeToPublisher |
Helper function to merge/concat values of each MaybeSource provided by a Publisher.
|
Copyright © 2019. All rights reserved.