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

public final Class MaybeFromSupplier<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 a supplier and signals its value as success or signals an exception.
Since
3.0.0

Field Summary

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

Constructor Summary

AccessConstructor and Description
public
MaybeFromSupplier(Supplier<? extends T> supplier)

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

supplierback to summary
pack-priv final Supplier<? extends T> supplier

Constructor Detail

MaybeFromSupplierback to summary
public MaybeFromSupplier(Supplier<? extends T> supplier)

Method Detail

getback to summary
public T get() throws Throwable

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
Exceptions
Throwable:
if the implementation wishes to throw any type of exception
subscribeActualback to summary
protected void subscribeActual(MaybeObserver<? super T> observer)
Annotations
@Override