public final Class MaybeFromFuture<T>

Class Inheritance

extends Maybe<T>

java.lang.Object
io.reactivex.rxjava3.core.Maybe
io.reactivex.rxjava3.internal.operators.maybe.MaybeFromFuture

Type Parameters

<T>: the value type

Imports

java.util.concurrent.*, io.reactivex.rxjava3.core.*, io.reactivex.rxjava3.disposables.*, io.reactivex.rxjava3.exceptions.Exceptions

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

Constructor Summary

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> observer)

Inherited from io.reactivex.rxjava3.core.Maybe:: amb ambArray ambWith blockingGet blockingGet blockingSubscribe blockingSubscribe blockingSubscribe blockingSubscribe blockingSubscribe cache cast compose concat concat concat concat concat concat concatArray concatArrayDelayError concatArrayEager concatArrayEagerDelayError concatDelayError concatDelayError concatDelayError concatEager concatEager concatEager concatEager concatEagerDelayError concatEagerDelayError concatEagerDelayError concatEagerDelayError concatMap concatMapCompletable concatMapSingle concatWith contains count create defaultIfEmpty defer delay delay delay delay delay delaySubscription delaySubscription delaySubscription dematerialize doAfterSuccess doAfterTerminate doFinally doOnComplete doOnDispose doOnError doOnEvent doOnLifecycle doOnSubscribe doOnSuccess doOnTerminate empty error error filter flatMap flatMap flatMap flatMapCompletable flatMapObservable flatMapPublisher flatMapSingle flattenAsFlowable flattenAsObservable flattenStreamAsFlowable flattenStreamAsObservable fromAction fromCallable fromCompletable fromCompletionStage fromFuture fromFuture fromObservable fromOptional fromPublisher fromRunnable fromSingle fromSupplier hide ignoreElement isEmpty just lift map mapOptional materialize merge merge merge merge merge merge merge mergeArray mergeArrayDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeWith never observeOn ofType onErrorComplete onErrorComplete onErrorResumeNext onErrorResumeWith onErrorReturn onErrorReturnItem onTerminateDetach repeat repeat repeatUntil repeatWhen retry retry retry retry retry retryUntil retryWhen safeSubscribe sequenceEqual sequenceEqual startWith startWith startWith startWith startWith subscribe subscribe subscribe subscribe subscribe subscribe subscribeActual subscribeOn subscribeWith switchIfEmpty switchIfEmpty switchOnNext switchOnNextDelayError takeUntil takeUntil test test timeInterval timeInterval timeInterval timeInterval timeout timeout timeout timeout timeout timeout timeout timeout timer timer timestamp timestamp timestamp timestamp to toCompletionStage toCompletionStage toFlowable toFuture toObservable 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
protected void subscribeActual(MaybeObserver<? super T> observer) Annotations @Override