public final class PromiseCombiner
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private Promise<java.lang.Void> |
aggregatePromise |
private java.lang.Throwable |
cause |
private boolean |
doneAdding |
private int |
doneCount |
private int |
expectedCount |
private GenericFutureListener<Future<?>> |
listener |
Constructor and Description |
---|
PromiseCombiner() |
Modifier and Type | Method and Description |
---|---|
void |
add(Promise promise) |
void |
addAll(Promise... promises) |
private void |
checkAddAllowed() |
void |
finish(Promise<java.lang.Void> aggregatePromise) |
private boolean |
tryPromise() |
private int expectedCount
private int doneCount
private boolean doneAdding
private Promise<java.lang.Void> aggregatePromise
private java.lang.Throwable cause
private final GenericFutureListener<Future<?>> listener