Class FlowableLastStageSubscriber<T>
java.lang.Object
java.util.concurrent.CompletableFuture<T>
io.reactivex.rxjava3.internal.jdk8.FlowableStageSubscriber<T>
io.reactivex.rxjava3.internal.jdk8.FlowableLastStageSubscriber<T>
- Type Parameters:
T
- the element type
- All Implemented Interfaces:
FlowableSubscriber<T>
,CompletionStage<T>
,Future<T>
,org.reactivestreams.Subscriber<T>
Signals the last element of the source via the underlying CompletableFuture,
signals the a default item if the upstream is empty or signals
NoSuchElementException
.- Since:
- 3.0.0
-
Nested Class Summary
Nested classes/interfaces inherited from class java.util.concurrent.CompletableFuture
CompletableFuture.AsynchronousCompletionTask
Nested classes/interfaces inherited from interface java.util.concurrent.Future
Future.State
-
Field Summary
FieldsFields inherited from class io.reactivex.rxjava3.internal.jdk8.FlowableStageSubscriber
upstream, value
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected void
afterSubscribe
(org.reactivestreams.Subscription s) void
void
Methods inherited from class io.reactivex.rxjava3.internal.jdk8.FlowableStageSubscriber
cancel, cancelUpstream, clear, complete, completeExceptionally, onError, onSubscribe
Methods inherited from class java.util.concurrent.CompletableFuture
acceptEither, acceptEitherAsync, acceptEitherAsync, allOf, anyOf, applyToEither, applyToEitherAsync, applyToEitherAsync, completeAsync, completeAsync, completedFuture, completedStage, completeOnTimeout, copy, defaultExecutor, delayedExecutor, delayedExecutor, exceptionally, exceptionallyAsync, exceptionallyAsync, exceptionallyCompose, exceptionallyComposeAsync, exceptionallyComposeAsync, exceptionNow, failedFuture, failedStage, get, get, getNow, getNumberOfDependents, handle, handleAsync, handleAsync, isCancelled, isCompletedExceptionally, isDone, join, minimalCompletionStage, newIncompleteFuture, obtrudeException, obtrudeValue, orTimeout, resultNow, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, runAsync, runAsync, state, supplyAsync, supplyAsync, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, toString, whenComplete, whenCompleteAsync, whenCompleteAsync
-
Field Details
-
hasDefault
final boolean hasDefault -
defaultItem
-
-
Constructor Details
-
FlowableLastStageSubscriber
-
-
Method Details
-
onNext
-
onComplete
public void onComplete() -
afterSubscribe
protected void afterSubscribe(org.reactivestreams.Subscription s) - Specified by:
afterSubscribe
in classFlowableStageSubscriber<T>
-