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

public final Class CompletableToSingle<T>

extends Single<T>
Class Inheritance
Imports
java.util.concurrent.Callable, io.reactivex.*, io.reactivex.disposables.Disposable, io.reactivex.exceptions.Exceptions

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 Callable<? extends T>
completionValueSupplier

pack-priv final CompletableSource
source

Constructor Summary

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

Method Summary

Modifier and TypeMethod and Description
protected void
subscribeActual(final SingleObserver<? super T>
the SingleObserver to handle, not null
observer)

Implements abstract io.reactivex.Single.subscribeActual.

Implement this method in subclasses to handle the incoming SingleObservers.
Inherited from io.reactivex.Single:
ambambArrayambWithasblockingGetcachecastcomposeconcatconcatconcatconcatconcatconcatconcatconcatArrayconcatArrayEagerconcatEagerconcatEagerconcatWithcontainscontainscreatedeferdelaydelaydelaydelaydelaySubscriptiondelaySubscriptiondelaySubscriptiondelaySubscriptiondelaySubscriptiondelaySubscriptiondematerializedoAfterSuccessdoAfterTerminatedoFinallydoOnDisposedoOnErrordoOnEventdoOnSubscribedoOnSuccessdoOnTerminateequalserrorerrorfilterflatMapflatMapCompletableflatMapMaybeflatMapObservableflatMapPublisherflattenAsFlowableflattenAsObservablefromCallablefromFuturefromFuturefromFuturefromFuturefromObservablefromPublisherhideignoreElementjustliftmapmaterializemergemergemergemergemergemergemergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeWithneverobserveOnonErrorResumeNextonErrorResumeNextonErrorReturnonErrorReturnItemonTerminateDetachrepeatrepeatrepeatUntilrepeatWhenretryretryretryretryretryretryWhensubscribesubscribesubscribesubscribesubscribesubscribeOnsubscribeWithtakeUntiltakeUntiltakeUntiltesttesttimeouttimeouttimeouttimeouttimertimertotoCompletabletoFlowabletoFuturetoMaybetoObservableunsafeCreateunsubscribeOnusingusingwrapzipzipzipzipzipzipzipzipzipzipArrayzipWith

Field Detail

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

Constructor Detail

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

Method Detail

subscribeActualback to summary
protected void subscribeActual(final SingleObserver<? super T> observer)

Implements abstract io.reactivex.Single.subscribeActual.

Doc from io.reactivex.Single.subscribeActual.

Implement this method in subclasses to handle the incoming SingleObservers.

There is no need to call any of the plugin hooks on the current Single instance or the SingleObserver; all hooks and basic safeguards have been applied by subscribe(SingleObserver) before this method gets called.

Parameters
observer:SingleObserver<? super T>

the SingleObserver to handle, not null

Annotations
@Override
io.reactivex.internal.operators.completable back to summary

pack-priv final Class CompletableToSingle.ToSingle

extends Object
implements CompletableObserver
Class Inheritance
  • java.lang.Object
  • io.reactivex.internal.operators.completable.CompletableToSingle.ToSingle
All Implemented Interfaces
io.reactivex.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.CompletableObserver.onComplete.

Called once the deferred computation completes normally.
public void
onError(Throwable
the exception, not null.
e)

Implements io.reactivex.CompletableObserver.onError.

Called once if the deferred computation 'throws' an exception.
public void
onSubscribe(Disposable
the Disposable instance to call dispose on for cancellation, not null
d)

Implements io.reactivex.CompletableObserver.onSubscribe.

Called once by the Completable to set a Disposable on this instance which then can be used to cancel the subscription at any time.
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.CompletableObserver.onComplete.

Doc from io.reactivex.CompletableObserver.onComplete.

Called once the deferred computation completes normally.

Annotations
@Override
onErrorback to summary
public void onError(Throwable e)

Implements io.reactivex.CompletableObserver.onError.

Doc from io.reactivex.CompletableObserver.onError.

Called once if the deferred computation 'throws' an exception.

Parameters
e:Throwable

the exception, not null.

Annotations
@Override
onSubscribeback to summary
public void onSubscribe(Disposable d)

Implements io.reactivex.CompletableObserver.onSubscribe.

Doc from io.reactivex.CompletableObserver.onSubscribe.

Called once by the Completable to set a Disposable on this instance which then can be used to cancel the subscription at any time.

Parameters
d:Disposable

the Disposable instance to call dispose on for cancellation, not null

Annotations
@Override