Class CancellationPropagatingFuture<T>

java.lang.Object

java.util.concurrent.CompletableFuture<T>

com.github.mizosoft.methanol.internal.concurrent.CancellationPropagatingFuture<T>

All Implemented Interfaces:

CompletionStage<T>, Future<T>

public final class CancellationPropagatingFuture<T>
extends CompletableFuture<T>

A CompletableFuture that propagates cancellation to an upstream when a node in the dependency tree starting from this future is canceled.

Nested Class Summary

Nested classes/interfaces inherited from class CompletableFuture

CompletableFuture.AsynchronousCompletionTask

Nested classes/interfaces inherited from interface Future

Future.State

Method Summary

Modifier and Type	Method	Description
boolean	cancel(boolean mayInterruptIfRunning)
static <T> CancellationPropagatingFuture<T>	create()
<U> CompletableFuture<U>	newIncompleteFuture()
static <T> CompletableFuture<T>	of(CompletableFuture<T> upstream)
static <T> CompletionStage<T>	of(CompletionStage<T> upstream)
<U> CompletableFuture<U>	thenCompose(Function<? super T, ? extends CompletionStage<U>> fn)
<U> CompletableFuture<U>	thenComposeAsync(Function<? super T, ? extends CompletionStage<U>> fn)
<U> CompletableFuture<U>	thenComposeAsync(Function<? super T, ? extends CompletionStage<U>> fn, Executor executor)

Methods inherited from class CompletableFuture

acceptEither, acceptEitherAsync, acceptEitherAsync, allOf, anyOf, applyToEither, applyToEitherAsync, applyToEitherAsync, complete, completeAsync, completeAsync, completedFuture, completedStage, completeExceptionally, 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, 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, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, toString, whenComplete, whenCompleteAsync, whenCompleteAsync

Methods inherited from class Object

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

Method Details

newIncompleteFuture

public <U> CompletableFuture<U> newIncompleteFuture()

Overrides:

newIncompleteFuture in class CompletableFuture<T>

thenCompose

public <U> CompletableFuture<U> thenCompose(Function<? super T, ? extends CompletionStage<U>> fn)

Specified by:

thenCompose in interface CompletionStage<T>

Overrides:

thenCompose in class CompletableFuture<T>

thenComposeAsync

public <U> CompletableFuture<U> thenComposeAsync(Function<? super T, ? extends CompletionStage<U>> fn)

Specified by:

thenComposeAsync in interface CompletionStage<T>

Overrides:

thenComposeAsync in class CompletableFuture<T>

thenComposeAsync

public <U> CompletableFuture<U> thenComposeAsync(Function<? super T, ? extends CompletionStage<U>> fn,
 Executor executor)

Specified by:

thenComposeAsync in interface CompletionStage<T>

Overrides:

thenComposeAsync in class CompletableFuture<T>

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<T>

Overrides:

cancel in class CompletableFuture<T>

create

public static <T> CancellationPropagatingFuture<T> create()

of

public static <T> CompletionStage<T> of(CompletionStage<T> upstream)

of

public static <T> CompletableFuture<T> of(CompletableFuture<T> upstream)