Class CompletionStageConsumer<T>
- java.lang.Object
-
- java.util.concurrent.CompletableFuture<T>
-
- io.reactivex.rxjava3.internal.jdk8.CompletionStageConsumer<T>
-
- Type Parameters:
T- the element type
- All Implemented Interfaces:
CompletableObserver,MaybeObserver<T>,SingleObserver<T>,java.util.concurrent.CompletionStage<T>,java.util.concurrent.Future<T>
public final class CompletionStageConsumer<T> extends java.util.concurrent.CompletableFuture<T> implements MaybeObserver<T>, SingleObserver<T>, CompletableObserver
Class that extends CompletableFuture and converts multiple types of reactive consumers and their signals into completion signals.- Since:
- 3.0.0
-
-
Field Summary
Fields Modifier and Type Field Description (package private) TdefaultItem(package private) booleanhasDefault(package private) java.util.concurrent.atomic.AtomicReference<Disposable>upstream
-
Constructor Summary
Constructors Constructor Description CompletionStageConsumer(boolean hasDefault, T defaultItem)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleancancel(boolean mayInterruptIfRunning)(package private) voidcancelUpstream()(package private) voidclear()booleancomplete(T value)booleancompleteExceptionally(java.lang.Throwable ex)voidonComplete()Called once the deferred computation completes normally.voidonError(java.lang.Throwable t)Notifies theMaybeObserverthat theMaybehas experienced an error condition.voidonSubscribe(@NonNull Disposable d)Provides theMaybeObserverwith the means of cancelling (disposing) the connection (channel) with theMaybein both synchronous (from withinonSubscribe(Disposable)itself) and asynchronous manner.voidonSuccess(T t)Notifies theMaybeObserverwith one item and that theMaybehas finished sending push-based notifications.-
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, failedFuture, failedStage, get, get, getNow, getNumberOfDependents, handle, handleAsync, handleAsync, isCancelled, isCompletedExceptionally, isDone, join, minimalCompletionStage, newIncompleteFuture, obtrudeException, obtrudeValue, orTimeout, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, runAsync, runAsync, 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 Detail
-
upstream
final java.util.concurrent.atomic.AtomicReference<Disposable> upstream
-
hasDefault
final boolean hasDefault
-
defaultItem
final T defaultItem
-
-
Constructor Detail
-
CompletionStageConsumer
public CompletionStageConsumer(boolean hasDefault, T defaultItem)
-
-
Method Detail
-
onSubscribe
public void onSubscribe(@NonNull @NonNull Disposable d)
Description copied from interface:MaybeObserverProvides theMaybeObserverwith the means of cancelling (disposing) the connection (channel) with theMaybein both synchronous (from withinonSubscribe(Disposable)itself) and asynchronous manner.- Specified by:
onSubscribein interfaceCompletableObserver- Specified by:
onSubscribein interfaceMaybeObserver<T>- Specified by:
onSubscribein interfaceSingleObserver<T>- Parameters:
d- theDisposableinstance whoseDisposable.dispose()can be called anytime to cancel the connection
-
onSuccess
public void onSuccess(@NonNull T t)
Description copied from interface:MaybeObserverNotifies theMaybeObserverwith one item and that theMaybehas finished sending push-based notifications.The
Maybewill not call this method if it callsMaybeObserver.onError(java.lang.Throwable).- Specified by:
onSuccessin interfaceMaybeObserver<T>- Specified by:
onSuccessin interfaceSingleObserver<T>- Parameters:
t- the item emitted by theMaybe
-
onError
public void onError(java.lang.Throwable t)
Description copied from interface:MaybeObserverNotifies theMaybeObserverthat theMaybehas experienced an error condition.If the
Maybecalls this method, it will not thereafter callMaybeObserver.onSuccess(T).- Specified by:
onErrorin interfaceCompletableObserver- Specified by:
onErrorin interfaceMaybeObserver<T>- Specified by:
onErrorin interfaceSingleObserver<T>- Parameters:
t- the exception encountered by theMaybe
-
onComplete
public void onComplete()
Description copied from interface:MaybeObserverCalled once the deferred computation completes normally.- Specified by:
onCompletein interfaceCompletableObserver- Specified by:
onCompletein interfaceMaybeObserver<T>
-
cancelUpstream
void cancelUpstream()
-
clear
void clear()
-
cancel
public boolean cancel(boolean mayInterruptIfRunning)
-
complete
public boolean complete(T value)
- Overrides:
completein classjava.util.concurrent.CompletableFuture<T>
-
completeExceptionally
public boolean completeExceptionally(java.lang.Throwable ex)
- Overrides:
completeExceptionallyin classjava.util.concurrent.CompletableFuture<T>
-
-