RxJava 2 2.2.21 · io.reactivex.internal.operators.maybe.MaybeFromFuture

Waits until the source Future completes or the wait times out; treats a null result as indication to signal onComplete instead of onSuccess.

Field Summary

Modifier and Type	Field and Description
pack-priv final Future<? extends T>	future
pack-priv final long	timeout
pack-priv final TimeUnit	unit

Access	Constructor and Description
public	MaybeFromFuture(Future<? extends T> future, long timeout, TimeUnit unit)

Method Summary

Modifier and Type	Method and Description
protected void	subscribeActual(MaybeObserver<? super T> the MaybeObserver to handle, not null observer) Implements abstract io.reactivex.Maybe.subscribeActual. Implement this method in subclasses to handle the incoming `MaybeObserver`s.

Inherited from io.reactivex.Maybe:: amb ambArray ambWith as blockingGet blockingGet cache cast compose concat concat concat concat concat concat concatArray concatArrayDelayError concatArrayEager concatDelayError concatDelayError concatEager concatEager concatMap concatWith contains count create defaultIfEmpty defer delay delay delay delaySubscription delaySubscription delaySubscription doAfterSuccess doAfterTerminate doFinally doOnComplete doOnDispose doOnError doOnEvent doOnSubscribe doOnSuccess doOnTerminate empty error error filter flatMap flatMap flatMap flatMapCompletable flatMapObservable flatMapPublisher flatMapSingle flatMapSingleElement flattenAsFlowable flattenAsObservable fromAction fromCallable fromCompletable fromFuture fromFuture fromRunnable fromSingle hide ignoreElement isEmpty just lift map materialize merge merge merge merge merge merge merge mergeArray mergeArrayDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeWith never observeOn ofType onErrorComplete onErrorComplete onErrorResumeNext onErrorResumeNext onErrorReturn onErrorReturnItem onExceptionResumeNext onTerminateDetach repeat repeat repeatUntil repeatWhen retry retry retry retry retry retryUntil retryWhen sequenceEqual sequenceEqual subscribe subscribe subscribe subscribe subscribe subscribeOn subscribeWith switchIfEmpty switchIfEmpty takeUntil takeUntil test test timeout timeout timeout timeout timeout timeout timeout timeout timer timer to toFlowable toObservable toSingle toSingle unsafeCreate unsubscribeOn using using wrap zip zip zip zip zip zip zip zip zip zipArray zipWith

Field Detail

future	back to summary
pack-priv final Future<? extends T> future

timeout	back to summary
pack-priv final long timeout

unit	back to summary
pack-priv final TimeUnit unit

Constructor Detail

MaybeFromFuture	back to summary
public MaybeFromFuture(Future<? extends T> future, long timeout, TimeUnit unit)

Method Detail

subscribeActual back to summary

subscribeActual	back to summary
protected void subscribeActual(MaybeObserver<? super T> observer) Implements abstract io.reactivex.Maybe.subscribeActual. Doc from io.reactivex.Maybe.subscribeActual. Implement this method in subclasses to handle the incoming `MaybeObserver`s. There is no need to call any of the plugin hooks on the current `Maybe` instance or the `MaybeObserver`; all hooks and basic safeguards have been applied by `subscribe(MaybeObserver)` before this method gets called. Parameters observer:MaybeObserver<? super T> the MaybeObserver to handle, not null Annotations @Override

protected void subscribeActual(MaybeObserver<? super T> observer)

Implements abstract io.reactivex.Maybe.subscribeActual.

Doc from io.reactivex.Maybe.subscribeActual.

Implement this method in subclasses to handle the incoming MaybeObservers.

There is no need to call any of the plugin hooks on the current Maybe instance or the MaybeObserver; all hooks and basic safeguards have been applied by subscribe(MaybeObserver) before this method gets called.

Parameters

observer:MaybeObserver<? super T>: the MaybeObserver to handle, not null

Annotations

@Override

public final Class MaybeFromFuture<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail