Class FlowableLastStageSubscriber<T>

java.lang.Object

java.util.concurrent.CompletableFuture<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>

public final class FlowableLastStageSubscriber<T>
extends CompletableFuture<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 CompletableFuture

CompletableFuture.AsynchronousCompletionTask

Nested classes/interfaces inherited from interface Future

Future.State

Constructor Summary

Constructors

Constructor	Description
FlowableLastStageSubscriber(boolean hasDefault, T defaultItem)

Method Summary

Modifier and Type	Method	Description
protected void	afterSubscribe(org.reactivestreams.Subscription s)
final boolean	cancel(boolean mayInterruptIfRunning)
protected final void	cancelUpstream()
protected final void	clear()
final boolean	complete(T value)
final boolean	completeExceptionally(Throwable ex)
void	onComplete()
final void	onError(Throwable t)
void	onNext(T t)
final void	onSubscribe(@NonNull org.reactivestreams.Subscription s)	Implementors of this method should make sure everything that needs to be visible in Subscriber.onNext(Object) is established before calling Subscription.request(long).

Methods inherited from class 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

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

FlowableLastStageSubscriber

public FlowableLastStageSubscriber(boolean hasDefault,
 T defaultItem)

Method Details

onNext

public void onNext(T t)

onComplete

public void onComplete()

afterSubscribe

protected void afterSubscribe(org.reactivestreams.Subscription s)

onSubscribe

public final void onSubscribe(@NonNull
 @NonNull org.reactivestreams.Subscription s)

Description copied from interface: FlowableSubscriber

Implementors of this method should make sure everything that needs to be visible in Subscriber.onNext(Object) is established before calling Subscription.request(long). In practice this means no initialization should happen after the request() call and additional behavior is thread safe in respect to onNext.

Specified by:

onSubscribe in interface FlowableSubscriber<T>

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<T>

onError

public final void onError(Throwable t)

Specified by:

onError in interface org.reactivestreams.Subscriber<T>

cancelUpstream

protected final void cancelUpstream()

clear

protected final void clear()

cancel

public final boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<T>

Overrides:

cancel in class CompletableFuture<T>

complete

public final boolean complete(T value)

Overrides:

complete in class CompletableFuture<T>

completeExceptionally

public final boolean completeExceptionally(Throwable ex)

Overrides:

completeExceptionally in class CompletableFuture<T>