Top Inners Fields Constructors Methods
io.reactivex.rxjava3.internal.operators.completable

public final Class CompletableToSingle<T>

extends Single<T>
Class Inheritance
Imports
io.reactivex.rxjava3.core.*, io.reactivex.rxjava3.disposables.Disposable, io.reactivex.rxjava3.exceptions.Exceptions, io.reactivex.rxjava3.functions.Supplier

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv class
CompletableToSingle.ToSingle

Field Summary

Modifier and TypeField and Description
pack-priv final T
completionValue

pack-priv final Supplier<? extends T>
completionValueSupplier

pack-priv final CompletableSource
source

Constructor Summary

AccessConstructor and Description
public
CompletableToSingle(CompletableSource source, Supplier<? extends T> completionValueSupplier, T completionValue)

Method Summary

Modifier and TypeMethod and Description
protected void
subscribeActual(final SingleObserver<? super T> observer)

Inherited from io.reactivex.rxjava3.core.Single:
ambambArrayambWithblockingGetblockingSubscribeblockingSubscribeblockingSubscribeblockingSubscribecachecastcomposeconcatconcatconcatconcatconcatconcatconcatconcatArrayconcatArrayDelayErrorconcatArrayEagerconcatArrayEagerDelayErrorconcatDelayErrorconcatDelayErrorconcatDelayErrorconcatEagerconcatEagerconcatEagerconcatEagerconcatEagerDelayErrorconcatEagerDelayErrorconcatEagerDelayErrorconcatEagerDelayErrorconcatMapconcatMapCompletableconcatMapMaybeconcatWithcontainscontainscreatedeferdelaydelaydelaydelaydelaySubscriptiondelaySubscriptiondelaySubscriptiondelaySubscriptiondelaySubscriptiondelaySubscriptiondematerializedoAfterSuccessdoAfterTerminatedoFinallydoOnDisposedoOnErrordoOnEventdoOnLifecycledoOnSubscribedoOnSuccessdoOnTerminateerrorerrorfilterflatMapflatMapflatMapflatMapCompletableflatMapMaybeflatMapObservableflatMapPublisherflattenAsFlowableflattenAsObservableflattenStreamAsFlowableflattenStreamAsObservablefromCallablefromCompletionStagefromFuturefromFuturefromMaybefromMaybefromObservablefromPublisherfromSupplierhideignoreElementjustliftmapmapOptionalmaterializemergemergemergemergemergemergemergeArraymergeArrayDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeWithneverobserveOnofTypeonErrorCompleteonErrorCompleteonErrorResumeNextonErrorResumeWithonErrorReturnonErrorReturnItemonTerminateDetachrepeatrepeatrepeatUntilrepeatWhenretryretryretryretryretryretryUntilretryWhensafeSubscribesequenceEqualstartWithstartWithstartWithstartWithstartWithsubscribesubscribesubscribesubscribesubscribesubscribesubscribeActualsubscribeOnsubscribeWithswitchOnNextswitchOnNextDelayErrortakeUntiltakeUntiltakeUntiltesttesttimeIntervaltimeIntervaltimeIntervaltimeIntervaltimeouttimeouttimeouttimeouttimertimertimestamptimestamptimestamptimestamptotoCompletionStagetoFlowabletoFuturetoMaybetoObservableunsafeCreateunsubscribeOnusingusingwrapzipzipzipzipzipzipzipzipzipzipArrayzipWith

Field Detail

completionValueback to summary
pack-priv final T completionValue
completionValueSupplierback to summary
pack-priv final Supplier<? extends T> completionValueSupplier
sourceback to summary
pack-priv final CompletableSource source

Constructor Detail

CompletableToSingleback to summary
public CompletableToSingle(CompletableSource source, Supplier<? extends T> completionValueSupplier, T completionValue)

Method Detail

subscribeActualback to summary
protected void subscribeActual(final SingleObserver<? super T> observer)
Annotations
@Override
io.reactivex.rxjava3.internal.operators.completable back to summary

pack-priv final Class CompletableToSingle.ToSingle

extends Object
implements CompletableObserver
Class Inheritance
  • java.lang.Object
  • io.reactivex.rxjava3.internal.operators.completable.CompletableToSingle.ToSingle
All Implemented Interfaces
io.reactivex.rxjava3.core.CompletableObserver

Field Summary

Modifier and TypeField and Description
private final SingleObserver<? super T>
observer

Constructor Summary

AccessConstructor and Description
pack-priv
ToSingle(SingleObserver<? super T> observer)

Method Summary

Modifier and TypeMethod and Description
public void
onComplete()

Implements io.reactivex.rxjava3.core.CompletableObserver.onComplete.

Called once the deferred computation completes normally.
public void
onError(Throwable e)

public void
onSubscribe(Disposable d)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

observerback to summary
private final SingleObserver<? super T> observer

Constructor Detail

ToSingleback to summary
pack-priv ToSingle(SingleObserver<? super T> observer)

Method Detail

onCompleteback to summary
public void onComplete()

Implements io.reactivex.rxjava3.core.CompletableObserver.onComplete.

Doc from io.reactivex.rxjava3.core.CompletableObserver.onComplete.

Called once the deferred computation completes normally.

Annotations
@Override
onErrorback to summary
public void onError(Throwable e)
Annotations
@Override
onSubscribeback to summary
public void onSubscribe(Disposable d)
Annotations
@Override