RxJava 3 3.1.8 · io.reactivex.rxjava3.internal.operators.single.SingleFromSupplier

Calls a supplier and emits its value or exception to the incoming SingleObserver.

Field Summary

Modifier and Type	Field and Description
pack-priv final Supplier<? extends T>	supplier

Constructor Summary

Access	Constructor and Description
public	SingleFromSupplier(Supplier<? extends T> supplier)

Method Summary

Modifier and Type	Method and Description
protected void	subscribeActual(SingleObserver<? super T> observer)

Inherited from io.reactivex.rxjava3.core.Single:: amb ambArray ambWith blockingGet blockingSubscribe blockingSubscribe blockingSubscribe blockingSubscribe cache cast compose concat concat concat concat concat concat concat concatArray concatArrayDelayError concatArrayEager concatArrayEagerDelayError concatDelayError concatDelayError concatDelayError concatEager concatEager concatEager concatEager concatEagerDelayError concatEagerDelayError concatEagerDelayError concatEagerDelayError concatMap concatMapCompletable concatMapMaybe concatWith contains contains create defer delay delay delay delay delaySubscription delaySubscription delaySubscription delaySubscription delaySubscription delaySubscription dematerialize doAfterSuccess doAfterTerminate doFinally doOnDispose doOnError doOnEvent doOnLifecycle doOnSubscribe doOnSuccess doOnTerminate error error filter flatMap flatMap flatMap flatMapCompletable flatMapMaybe flatMapObservable flatMapPublisher flattenAsFlowable flattenAsObservable flattenStreamAsFlowable flattenStreamAsObservable fromCallable fromCompletionStage fromFuture fromFuture fromMaybe fromMaybe fromObservable fromPublisher fromSupplier hide ignoreElement just lift map mapOptional materialize merge merge merge merge merge merge mergeArray mergeArrayDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeWith never observeOn ofType onErrorComplete onErrorComplete onErrorResumeNext onErrorResumeWith onErrorReturn onErrorReturnItem onTerminateDetach repeat repeat repeatUntil repeatWhen retry retry retry retry retry retryUntil retryWhen safeSubscribe sequenceEqual startWith startWith startWith startWith startWith subscribe subscribe subscribe subscribe subscribe subscribe subscribeActual subscribeOn subscribeWith switchOnNext switchOnNextDelayError takeUntil takeUntil takeUntil test test timeInterval timeInterval timeInterval timeInterval timeout timeout timeout timeout timer timer timestamp timestamp timestamp timestamp to toCompletionStage toFlowable toFuture toMaybe toObservable unsafeCreate unsubscribeOn using using wrap zip zip zip zip zip zip zip zip zip zipArray zipWith

Field Detail

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

Constructor Detail

SingleFromSupplier	back to summary
public SingleFromSupplier(Supplier<? extends T> supplier)

Method Detail

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

public final Class SingleFromSupplier<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail