Top Description Inners Fields Constructors Methods
io.reactivex.rxjava3.internal.jdk8

public final Class SingleFromCompletionStage<T>

extends Single<T>
Class Inheritance
Type Parameters
<T>
the element type
Imports
java.util.concurrent.CompletionStage, java.util.function.BiConsumer, io.reactivex.rxjava3.core.*, io.reactivex.rxjava3.disposables.Disposable, io.reactivex.rxjava3.internal.jdk8.FlowableFromCompletionStage.BiConsumerAtomicReference
Wrap a CompletionStage and signal its outcome.
Since
3.0.0

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
SingleFromCompletionStage.CompletionStageHandler<T>

Field Summary

Modifier and TypeField and Description
pack-priv final CompletionStage<T>
stage

Constructor Summary

AccessConstructor and Description
public
SingleFromCompletionStage(CompletionStage<T> stage)

Method Summary

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

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

Field Detail

stageback to summary
pack-priv final CompletionStage<T> stage

Constructor Detail

SingleFromCompletionStageback to summary
public SingleFromCompletionStage(CompletionStage<T> stage)

Method Detail

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

pack-priv final Class SingleFromCompletionStage.CompletionStageHandler<T>

extends Object
implements Disposable, BiConsumer<T, Throwable>
Class Inheritance
  • java.lang.Object
  • io.reactivex.rxjava3.internal.jdk8.SingleFromCompletionStage.CompletionStageHandler
All Implemented Interfaces
java.util.function.BiConsumer, io.reactivex.rxjava3.disposables.Disposable

Field Summary

Modifier and TypeField and Description
pack-priv final SingleObserver<? super T>
downstream

pack-priv final FlowableFromCompletionStage.BiConsumerAtomicReference<T>
whenReference

Constructor Summary

AccessConstructor and Description
pack-priv
CompletionStageHandler(SingleObserver<? super T> downstream, FlowableFromCompletionStage.BiConsumerAtomicReference<T> whenReference)

Method Summary

Modifier and TypeMethod and Description
public void
accept(T
the first input argument
item, Throwable
the second input argument
error)

Implements java.util.function.BiConsumer.accept.

Performs this operation on the given arguments.
public void
dispose()

Implements io.reactivex.rxjava3.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.
public boolean
isDisposed()

Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

downstreamback to summary
pack-priv final SingleObserver<? super T> downstream
whenReferenceback to summary
pack-priv final FlowableFromCompletionStage.BiConsumerAtomicReference<T> whenReference

Constructor Detail

CompletionStageHandlerback to summary
pack-priv CompletionStageHandler(SingleObserver<? super T> downstream, FlowableFromCompletionStage.BiConsumerAtomicReference<T> whenReference)

Method Detail

acceptback to summary
public void accept(T item, Throwable error)

Implements java.util.function.BiConsumer.accept.

Doc from java.util.function.BiConsumer.accept.

Performs this operation on the given arguments.

Parameters
item:T

the first input argument

error:Throwable

the second input argument

Annotations
@Override
disposeback to summary
public void dispose()

Implements io.reactivex.rxjava3.disposables.Disposable.dispose.

Doc from io.reactivex.rxjava3.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.

Annotations
@Override
isDisposedback to summary
public boolean isDisposed()

Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Doc from io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.

Returns:boolean

true if this resource has been disposed

Annotations
@Override