Top Description Fields Constructors Methods
io.reactivex.internal.operators.maybe

public final Class MaybeEmpty

extends Maybe<Object>
implements ScalarCallable<Object>
Class Inheritance
All Implemented Interfaces
io.reactivex.internal.fuseable.ScalarCallable, java.util.concurrent.Callable
Imports
io.reactivex.*, io.reactivex.internal.disposables.EmptyDisposable, io.reactivex.internal.fuseable.ScalarCallable

Signals an onComplete.

Field Summary

Modifier and TypeField and Description
public static final MaybeEmpty

Constructor Summary

AccessConstructor and Description
public

Method Summary

Modifier and TypeMethod and Description
public Object
call()

Implements io.reactivex.internal.fuseable.ScalarCallable.call.

Computes a result, or throws an exception if unable to do so.
protected void
subscribeActual(MaybeObserver<? super Object>
the MaybeObserver to handle, not null
observer
)

Implements abstract io.reactivex.Maybe.subscribeActual.

Implement this method in subclasses to handle the incoming MaybeObservers.
Inherited from io.reactivex.Maybe:
ambambArrayambWithasblockingGetblockingGetcachecastcomposeconcatconcatconcatconcatconcatconcatconcatArrayconcatArrayDelayErrorconcatArrayEagerconcatDelayErrorconcatDelayErrorconcatEagerconcatEagerconcatMapconcatWithcontainscountcreatedefaultIfEmptydeferdelaydelaydelaydelaySubscriptiondelaySubscriptiondelaySubscriptiondoAfterSuccessdoAfterTerminatedoFinallydoOnCompletedoOnDisposedoOnErrordoOnEventdoOnSubscribedoOnSuccessdoOnTerminateemptyerrorerrorfilterflatMapflatMapflatMapflatMapCompletableflatMapObservableflatMapPublisherflatMapSingleflatMapSingleElementflattenAsFlowableflattenAsObservablefromActionfromCallablefromCompletablefromFuturefromFuturefromRunnablefromSinglehideignoreElementisEmptyjustliftmapmaterializemergemergemergemergemergemergemergemergeArraymergeArrayDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeWithneverobserveOnofTypeonErrorCompleteonErrorCompleteonErrorResumeNextonErrorResumeNextonErrorReturnonErrorReturnItemonExceptionResumeNextonTerminateDetachrepeatrepeatrepeatUntilrepeatWhenretryretryretryretryretryretryUntilretryWhensequenceEqualsequenceEqualsubscribesubscribesubscribesubscribesubscribesubscribeOnsubscribeWithswitchIfEmptyswitchIfEmptytakeUntiltakeUntiltesttesttimeouttimeouttimeouttimeouttimeouttimeouttimeouttimeouttimertimertotoFlowabletoObservabletoSingletoSingleunsafeCreateunsubscribeOnusingusingwrapzipzipzipzipzipzipzipzipzipzipArrayzipWith

Field Detail

INSTANCEback to summary
public static final MaybeEmpty INSTANCE

Constructor Detail

MaybeEmptyback to summary
public MaybeEmpty()

Method Detail

callback to summary
public Object call()

Implements io.reactivex.internal.fuseable.ScalarCallable.call.

Doc from java.util.concurrent.Callable.call.

Computes a result, or throws an exception if unable to do so.

Returns:Object

computed result

Annotations
@Override
subscribeActualback to summary
protected void subscribeActual(MaybeObserver<? super Object> 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 Object>

the MaybeObserver to handle, not null

Annotations
@Override