com.hazelcast.internal.util.futures

Class ChainingFuture<T>

java.lang.Object

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

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

Type Parameters:

T -

All Implemented Interfaces:

ICompletableFuture<T>, Future<T>

public class ChainingFuture<T>
extends AbstractCompletableFuture<T>

Iterates over supplied ICompletableFuture 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

Constructor Summary

Constructors

Constructor and Description
ChainingFuture(Iterator<ICompletableFuture<T>> futuresToChain, Executor executor, ChainingFuture.ExceptionHandler exceptionHandler, ILogger logger)

Method Summary

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

andThen, andThen, cancel, cancelled, done, get, get, getResult, isCancelled, isDone, setResult, shouldCancel

Methods inherited from class java.lang.Object

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

Constructor Detail

ChainingFuture

public ChainingFuture(Iterator<ICompletableFuture<T>> futuresToChain,
                      Executor executor,
                      ChainingFuture.ExceptionHandler exceptionHandler,
                      ILogger logger)