Class FlowableStageSubscriber<T>

java.lang.Object

java.util.concurrent.CompletableFuture<T>

io.reactivex.rxjava3.internal.jdk8.FlowableStageSubscriber<T>

Type Parameters:

T - the element type

All Implemented Interfaces:

FlowableSubscriber<T>, CompletionStage<T>, Future<T>, org.reactivestreams.Subscriber<T>

Direct Known Subclasses:

FlowableFirstStageSubscriber, FlowableLastStageSubscriber, FlowableSingleStageSubscriber

abstract class FlowableStageSubscriber<T>
extends CompletableFuture<T>
implements FlowableSubscriber<T>

Base class that extends CompletableFuture and provides basic infrastructure to notify watchers upon upstream signals.

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

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final AtomicReference<org.reactivestreams.Subscription>	upstream
(package private) T	value

Constructor Summary

Constructors

Constructor	Description
FlowableStageSubscriber()

Method Summary

Modifier and Type	Method	Description
protected abstract 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)
final void	onError(Throwable 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

Methods inherited from interface org.reactivestreams.Subscriber

onComplete, onNext

Field Details

upstream

final AtomicReference<org.reactivestreams.Subscription> upstream

value

T value

Constructor Details

FlowableStageSubscriber

FlowableStageSubscriber()

Method Details

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>

afterSubscribe

protected abstract void afterSubscribe(org.reactivestreams.Subscription s)

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>