public final Class MaybeDefer<T>

Class Inheritance

extends Maybe<T>

java.lang.Object
io.reactivex.Maybe
io.reactivex.internal.operators.maybe.MaybeDefer

Type Parameters

<T>: the value type

Imports

java.util.concurrent.Callable, io.reactivex.*, io.reactivex.exceptions.Exceptions, io.reactivex.internal.disposables.EmptyDisposable, io.reactivex.internal.functions.ObjectHelper

Defers the creation of the actual Maybe the incoming MaybeObserver is subscribed to.

Field Summary

Modifier and Type	Field and Description
pack-priv final Callable<? extends MaybeSource<? extends T>>	maybeSupplier

Constructor Summary

Access	Constructor and Description
public	MaybeDefer(Callable<? extends MaybeSource<? extends T>> maybeSupplier)

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

maybeSupplier	back to summary
pack-priv final Callable<? extends MaybeSource<? extends T>> maybeSupplier

Constructor Detail

MaybeDefer	back to summary
public MaybeDefer(Callable<? extends MaybeSource<? extends T>> maybeSupplier)

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