com.hazelcast.internal.util.futures

Class ChainingFuture<T>

java.lang.Object

java.util.concurrent.CompletableFuture<V>

com.hazelcast.spi.impl.InternalCompletableFuture<T>

com.hazelcast.internal.util.futures.ChainingFuture<T>

Type Parameters:

T -

All Implemented Interfaces:

CompletionStage<T>, Future<T>

public class ChainingFuture<T>
extends InternalCompletableFuture<T>

Iterates over supplied InternalCompletableFuture serially. It advances to the next future only when the previous future is completed. It completes when there is no other future available.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ChainingFuture.ExceptionHandler

Nested classes/interfaces inherited from class java.util.concurrent.CompletableFuture

CompletableFuture.AsynchronousCompletionTask

Constructor Summary

Constructors

Constructor and Description
ChainingFuture(Iterator<InternalCompletableFuture<T>> futuresToChain, ChainingFuture.ExceptionHandler exceptionHandler)

Method Summary

Methods inherited from class com.hazelcast.spi.impl.InternalCompletableFuture

completedExceptionally, completedExceptionally, completingCallback, joinInternal, newCompletedFuture, newCompletedFuture, newCompletedFuture, newCompletedFuture, newDelegatingFuture, withExecutor

Methods inherited from class java.util.concurrent.CompletableFuture

acceptEither, acceptEitherAsync, acceptEitherAsync, allOf, anyOf, applyToEither, applyToEitherAsync, applyToEitherAsync, cancel, complete, completedFuture, completeExceptionally, exceptionally, get, get, getNow, getNumberOfDependents, handle, handleAsync, handleAsync, isCancelled, isCompletedExceptionally, isDone, join, obtrudeException, obtrudeValue, 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

Methods inherited from class java.lang.Object

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

Constructor Detail

ChainingFuture

public ChainingFuture(Iterator<InternalCompletableFuture<T>> futuresToChain,
                      ChainingFuture.ExceptionHandler exceptionHandler)