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

public final Class FlowableFromCompletionStage<T>

extends Flowable<T>
Class Inheritance
Type Parameters
<T>
the element type
Imports
java.util.concurrent.CompletionStage, java.util.concurrent.atomic.AtomicReference, java.util.function.BiConsumer, org.reactivestreams.Subscriber, io.reactivex.rxjava3.core.Flowable, io.reactivex.rxjava3.internal.subscriptions.DeferredScalarSubscription
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
FlowableFromCompletionStage.BiConsumerAtomicReference<T>

pack-priv static class
FlowableFromCompletionStage.CompletionStageHandler<T>

Field Summary

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

Constructor Summary

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

Method Summary

Modifier and TypeMethod and Description
protected void
subscribeActual(Subscriber<? super T> s)

Inherited from io.reactivex.rxjava3.core.Flowable:
allambambArrayambWithanyblockingFirstblockingFirstblockingForEachblockingForEachblockingIterableblockingIterableblockingLastblockingLastblockingLatestblockingMostRecentblockingNextblockingSingleblockingSingleblockingStreamblockingStreamblockingSubscribeblockingSubscribeblockingSubscribeblockingSubscribeblockingSubscribeblockingSubscribeblockingSubscribeblockingSubscribebufferbufferbufferbufferbufferbufferbufferbufferbufferbufferbufferbufferbufferbufferbufferbufferbufferbufferSizecachecacheWithInitialCapacitycastcollectcollectcollectIntocombineLatestcombineLatestcombineLatestcombineLatestcombineLatestcombineLatestcombineLatestcombineLatestcombineLatestcombineLatestcombineLatestArraycombineLatestArraycombineLatestArrayDelayErrorcombineLatestArrayDelayErrorcombineLatestDelayErrorcombineLatestDelayErrorcomposeconcatconcatconcatconcatconcatconcatconcatArrayconcatArrayDelayErrorconcatArrayEagerconcatArrayEagerconcatArrayEagerDelayErrorconcatArrayEagerDelayErrorconcatDelayErrorconcatDelayErrorconcatDelayErrorconcatEagerconcatEagerconcatEagerconcatEagerconcatEagerDelayErrorconcatEagerDelayErrorconcatEagerDelayErrorconcatEagerDelayErrorconcatMapconcatMapconcatMapconcatMapCompletableconcatMapCompletableconcatMapCompletableDelayErrorconcatMapCompletableDelayErrorconcatMapCompletableDelayErrorconcatMapDelayErrorconcatMapDelayErrorconcatMapDelayErrorconcatMapEagerconcatMapEagerconcatMapEagerDelayErrorconcatMapEagerDelayErrorconcatMapIterableconcatMapIterableconcatMapMaybeconcatMapMaybeconcatMapMaybeDelayErrorconcatMapMaybeDelayErrorconcatMapMaybeDelayErrorconcatMapSingleconcatMapSingleconcatMapSingleDelayErrorconcatMapSingleDelayErrorconcatMapSingleDelayErrorconcatMapStreamconcatMapStreamconcatWithconcatWithconcatWithconcatWithcontainscountcreatedebouncedebouncedebouncedebouncedefaultIfEmptydeferdelaydelaydelaydelaydelaydelaydelaySubscriptiondelaySubscriptiondelaySubscriptiondematerializedistinctdistinctdistinctdistinctUntilChangeddistinctUntilChangeddistinctUntilChangeddoAfterNextdoAfterTerminatedoFinallydoOnCanceldoOnCompletedoOnEachdoOnEachdoOnErrordoOnLifecycledoOnNextdoOnRequestdoOnSubscribedoOnTerminateelementAtelementAtelementAtOrErroremptyerrorerrorfilterfirstfirstElementfirstOrErrorfirstOrErrorStagefirstStageflatMapflatMapflatMapflatMapflatMapflatMapflatMapflatMapflatMapflatMapflatMapflatMapflatMapCompletableflatMapCompletableflatMapIterableflatMapIterableflatMapIterableflatMapIterableflatMapMaybeflatMapMaybeflatMapSingleflatMapSingleflatMapStreamflatMapStreamforEachforEachWhileforEachWhileforEachWhilefromActionfromArrayfromCallablefromCompletablefromCompletionStagefromFuturefromFuturefromIterablefromMaybefromObservablefromOptionalfromPublisherfromRunnablefromSinglefromStreamfromSuppliergenerategenerategenerategenerategenerategroupBygroupBygroupBygroupBygroupBygroupBygroupJoinhideignoreElementsintervalintervalintervalintervalintervalRangeintervalRangeisEmptyjoinjustjustjustjustjustjustjustjustjustjustlastlastElementlastOrErrorlastOrErrorStagelastStageliftmapmapOptionalmaterializemergemergemergemergemergemergemergemergemergeArraymergeArraymergeArrayDelayErrormergeArrayDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeWithmergeWithmergeWithmergeWithneverobserveOnobserveOnobserveOnofTypeonBackpressureBufferonBackpressureBufferonBackpressureBufferonBackpressureBufferonBackpressureBufferonBackpressureBufferonBackpressureBufferonBackpressureBufferonBackpressureBufferonBackpressureBufferonBackpressureDroponBackpressureDroponBackpressureLatestonBackpressureLatestonBackpressureReduceonBackpressureReduceonErrorCompleteonErrorCompleteonErrorResumeNextonErrorResumeWithonErrorReturnonErrorReturnItemonTerminateDetachparallelparallelparallelpublishpublishpublishpublishrangerangeLongrebatchRequestsreducereducereduceWithrepeatrepeatrepeatUntilrepeatWhenreplayreplayreplayreplayreplayreplayreplayreplayreplayreplayreplayreplayreplayreplayreplayreplayreplayreplayretryretryretryretryretryretryUntilretryWhensafeSubscribesamplesamplesamplesamplesamplesamplesamplescanscanscanWithsequenceEqualsequenceEqualsequenceEqualsequenceEqualserializesharesinglesingleElementsingleOrErrorsingleOrErrorStagesingleStageskipskipskipskipLastskipLastskipLastskipLastskipLastskipLastskipUntilskipWhilesortedsortedstartWithstartWithstartWithstartWithstartWithArraystartWithItemstartWithIterablesubscribesubscribesubscribesubscribesubscribesubscribesubscribesubscribeActualsubscribeOnsubscribeOnsubscribeWithswitchIfEmptyswitchMapswitchMapswitchMapCompletableswitchMapCompletableDelayErrorswitchMapDelayErrorswitchMapDelayErrorswitchMapMaybeswitchMapMaybeDelayErrorswitchMapSingleswitchMapSingleDelayErrorswitchOnNextswitchOnNextswitchOnNextDelayErrorswitchOnNextDelayErrortaketaketaketakeLasttakeLasttakeLasttakeLasttakeLasttakeLasttakeLasttakeLasttakeLasttakeUntiltakeUntiltakeWhiletesttesttestthrottleFirstthrottleFirstthrottleFirstthrottleLastthrottleLastthrottleLastthrottleLatestthrottleLatestthrottleLatestthrottleLatestthrottleLatestthrottleWithTimeoutthrottleWithTimeoutthrottleWithTimeouttimeIntervaltimeIntervaltimeIntervaltimeIntervaltimeouttimeouttimeouttimeouttimeouttimeouttimeouttimeouttimertimertimestamptimestamptimestamptimestamptotoFuturetoListtoListtoListtoMaptoMaptoMaptoMultimaptoMultimaptoMultimaptoMultimaptoObservabletoSortedListtoSortedListtoSortedListtoSortedListunsafeCreateunsubscribeOnusingusingwindowwindowwindowwindowwindowwindowwindowwindowwindowwindowwindowwindowwindowwindowwindowwindowwindowwithLatestFromwithLatestFromwithLatestFromwithLatestFromwithLatestFromwithLatestFromzipzipzipzipzipzipzipzipzipzipzipzipzipArrayzipWithzipWithzipWithzipWith

Field Detail

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

Constructor Detail

FlowableFromCompletionStageback to summary
public FlowableFromCompletionStage(CompletionStage<T> stage)

Method Detail

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

pack-priv final Class FlowableFromCompletionStage.BiConsumerAtomicReference<T>

extends AtomicReference<BiConsumer<T, Throwable>>
implements BiConsumer<T, Throwable>
Class Inheritance
All Implemented Interfaces
java.util.function.BiConsumer

Field Summary

Modifier and TypeField and Description
private static final long
serialVersionUID

Hides java.util.concurrent.atomic.AtomicReference.serialVersionUID.

Constructor Summary

AccessConstructor and Description
pack-priv
BiConsumerAtomicReference()

Method Summary

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

Implements java.util.function.BiConsumer.accept.

Performs this operation on the given arguments.
Inherited from java.util.concurrent.atomic.AtomicReference:
accumulateAndGetcompareAndExchangecompareAndExchangeAcquirecompareAndExchangeReleasecompareAndSetgetgetAcquiregetAndAccumulategetAndSetgetAndUpdategetOpaquegetPlainlazySetsetsetOpaquesetPlainsetReleasetoStringupdateAndGetweakCompareAndSetweakCompareAndSetAcquireweakCompareAndSetPlainweakCompareAndSetReleaseweakCompareAndSetVolatile

Field Detail

serialVersionUIDback to summary
private static final long serialVersionUID

Hides java.util.concurrent.atomic.AtomicReference.serialVersionUID.

Constructor Detail

BiConsumerAtomicReferenceback to summary
pack-priv BiConsumerAtomicReference()

Method Detail

acceptback to summary
public void accept(T t, Throwable u)

Implements java.util.function.BiConsumer.accept.

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

Performs this operation on the given arguments.

Parameters
t:T

the first input argument

u:Throwable

the second input argument

Annotations
@Override
io.reactivex.rxjava3.internal.jdk8 back to summary

pack-priv final Class FlowableFromCompletionStage.CompletionStageHandler<T>

extends DeferredScalarSubscription<T>
implements BiConsumer<T, Throwable>
Class Inheritance
All Implemented Interfaces
java.util.function.BiConsumer

Field Summary

Modifier and TypeField and Description
private static final long
serialVersionUID

Hides io.reactivex.rxjava3.internal.subscriptions.DeferredScalarSubscription.serialVersionUID.

pack-priv final FlowableFromCompletionStage.BiConsumerAtomicReference<T>
whenReference

Inherited from io.reactivex.rxjava3.internal.subscriptions.DeferredScalarSubscription:
downstreamvalue

Constructor Summary

AccessConstructor and Description
pack-priv
CompletionStageHandler(Subscriber<? 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
cancel()

Overrides io.reactivex.rxjava3.internal.subscriptions.DeferredScalarSubscription.cancel.

Implements org.reactivestreams.Subscription.cancel.

Request the Publisher to stop sending data and clean up resources.
Inherited from io.reactivex.rxjava3.internal.subscriptions.DeferredScalarSubscription:
clearcompleteisCancelledisEmptypollrequestrequestFusiontryCancel

Field Detail

serialVersionUIDback to summary
private static final long serialVersionUID

Hides io.reactivex.rxjava3.internal.subscriptions.DeferredScalarSubscription.serialVersionUID.

whenReferenceback to summary
pack-priv final FlowableFromCompletionStage.BiConsumerAtomicReference<T> whenReference

Constructor Detail

CompletionStageHandlerback to summary
pack-priv CompletionStageHandler(Subscriber<? 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
cancelback to summary
public void cancel()

Overrides io.reactivex.rxjava3.internal.subscriptions.DeferredScalarSubscription.cancel.

Implements org.reactivestreams.Subscription.cancel.

Doc from org.reactivestreams.Subscription.cancel.

Request the Publisher to stop sending data and clean up resources.

Data may still be sent to meet previously signalled demand after calling cancel.

Annotations
@Override