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

public final Class MaybeFromRunnable<T>

extends Maybe<T>
implements Supplier<T>
Class Inheritance
All Implemented Interfaces
io.reactivex.rxjava3.functions.Supplier
Type Parameters
<T>
the value type
Imports
io.reactivex.rxjava3.core.*, io.reactivex.rxjava3.disposables.*, io.reactivex.rxjava3.exceptions.Exceptions, io.reactivex.rxjava3.functions.Supplier, io.reactivex.rxjava3.plugins.RxJavaPlugins
Executes an Runnable and signals its exception or completes normally.

Field Summary

Modifier and TypeField and Description
pack-priv final Runnable
runnable

Constructor Summary

AccessConstructor and Description
public
MaybeFromRunnable(Runnable runnable)

Method Summary

Modifier and TypeMethod and Description
public T
get()

Implements io.reactivex.rxjava3.functions.Supplier.get.

Produces a value or throws an exception.
protected void
subscribeActual(MaybeObserver<? super T> observer)

Inherited from io.reactivex.rxjava3.core.Maybe:
ambambArrayambWithblockingGetblockingGetblockingSubscribeblockingSubscribeblockingSubscribeblockingSubscribeblockingSubscribecachecastcomposeconcatconcatconcatconcatconcatconcatconcatArrayconcatArrayDelayErrorconcatArrayEagerconcatArrayEagerDelayErrorconcatDelayErrorconcatDelayErrorconcatDelayErrorconcatEagerconcatEagerconcatEagerconcatEagerconcatEagerDelayErrorconcatEagerDelayErrorconcatEagerDelayErrorconcatEagerDelayErrorconcatMapconcatMapCompletableconcatMapSingleconcatWithcontainscountcreatedefaultIfEmptydeferdelaydelaydelaydelaydelaydelaySubscriptiondelaySubscriptiondelaySubscriptiondematerializedoAfterSuccessdoAfterTerminatedoFinallydoOnCompletedoOnDisposedoOnErrordoOnEventdoOnLifecycledoOnSubscribedoOnSuccessdoOnTerminateemptyerrorerrorfilterflatMapflatMapflatMapflatMapCompletableflatMapObservableflatMapPublisherflatMapSingleflattenAsFlowableflattenAsObservableflattenStreamAsFlowableflattenStreamAsObservablefromActionfromCallablefromCompletablefromCompletionStagefromFuturefromFuturefromObservablefromOptionalfromPublisherfromRunnablefromSinglefromSupplierhideignoreElementisEmptyjustliftmapmapOptionalmaterializemergemergemergemergemergemergemergemergeArraymergeArrayDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeWithneverobserveOnofTypeonErrorCompleteonErrorCompleteonErrorResumeNextonErrorResumeWithonErrorReturnonErrorReturnItemonTerminateDetachrepeatrepeatrepeatUntilrepeatWhenretryretryretryretryretryretryUntilretryWhensafeSubscribesequenceEqualsequenceEqualstartWithstartWithstartWithstartWithstartWithsubscribesubscribesubscribesubscribesubscribesubscribesubscribeActualsubscribeOnsubscribeWithswitchIfEmptyswitchIfEmptyswitchOnNextswitchOnNextDelayErrortakeUntiltakeUntiltesttesttimeIntervaltimeIntervaltimeIntervaltimeIntervaltimeouttimeouttimeouttimeouttimeouttimeouttimeouttimeouttimertimertimestamptimestamptimestamptimestamptotoCompletionStagetoCompletionStagetoFlowabletoFuturetoObservabletoSingleunsafeCreateunsubscribeOnusingusingwrapzipzipzipzipzipzipzipzipzipzipArrayzipWith

Field Detail

runnableback to summary
pack-priv final Runnable runnable

Constructor Detail

MaybeFromRunnableback to summary
public MaybeFromRunnable(Runnable runnable)

Method Detail

getback to summary
public T get()

Implements io.reactivex.rxjava3.functions.Supplier.get.

Doc from io.reactivex.rxjava3.functions.Supplier.get.

Produces a value or throws an exception.

Returns:T

the value produced

Annotations
@Override
subscribeActualback to summary
protected void subscribeActual(MaybeObserver<? super T> observer)
Annotations
@Override