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

public final Class MaybeFromCallable<T>

extends Maybe<T>
implements Supplier<T>
Class Inheritance
All Implemented Interfaces
io.reactivex.rxjava3.functions.Supplier
Type Parameters
<T>
the value type
Imports
java.util.concurrent.Callable, io.reactivex.rxjava3.core.*, io.reactivex.rxjava3.disposables.*, io.reactivex.rxjava3.exceptions.Exceptions, io.reactivex.rxjava3.functions.Supplier, io.reactivex.rxjava3.plugins.RxJavaPlugins
Executes a callable and signals its value as success or signals an exception.

Field Summary

Modifier and TypeField and Description
pack-priv final Callable<? extends T>
callable

Constructor Summary

AccessConstructor and Description
public
MaybeFromCallable(Callable<? extends T> callable)

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

callableback to summary
pack-priv final Callable<? extends T> callable

Constructor Detail

MaybeFromCallableback to summary
public MaybeFromCallable(Callable<? extends T> callable)

Method Detail

getback to summary
public T get() throws Exception

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