Package io.netty.util.concurrent
Class PromiseAggregator<V,F extends Future<V>>
java.lang.Object
io.netty.util.concurrent.PromiseAggregator<V,F>
- All Implemented Interfaces:
GenericFutureListener<F>
,EventListener
- Direct Known Subclasses:
ChannelPromiseAggregator
@Deprecated
public class PromiseAggregator<V,F extends Future<V>>
extends Object
implements GenericFutureListener<F>
Deprecated.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final Promise
<?> Deprecated.private final boolean
Deprecated.Deprecated. -
Constructor Summary
ConstructorsConstructorDescriptionPromiseAggregator
(Promise<Void> aggregatePromise) Deprecated.PromiseAggregator
(Promise<Void> aggregatePromise, boolean failPending) Deprecated.Creates a new instance. -
Method Summary
Modifier and TypeMethodDescriptionfinal PromiseAggregator
<V, F> Deprecated.Add the givenPromise
s to the aggregator.void
operationComplete
(F future) Deprecated.Invoked when the operation associated with theFuture
has been completed.
-
Field Details
-
aggregatePromise
Deprecated. -
failPending
private final boolean failPendingDeprecated. -
pendingPromises
Deprecated.
-
-
Constructor Details
-
PromiseAggregator
Deprecated.Creates a new instance.- Parameters:
aggregatePromise
- thePromise
to notifyfailPending
-true
to fail pending promises, false to leave them unaffected
-
PromiseAggregator
Deprecated.SeePromiseAggregator(Promise, boolean)
. DefaultsfailPending
to true.
-
-
Method Details
-
add
Deprecated.Add the givenPromise
s to the aggregator. -
operationComplete
Deprecated.Description copied from interface:GenericFutureListener
Invoked when the operation associated with theFuture
has been completed.- Specified by:
operationComplete
in interfaceGenericFutureListener<V>
- Parameters:
future
- the sourceFuture
which called this callback- Throws:
Exception
-
PromiseCombiner(EventExecutor)
.GenericFutureListener
implementation which consolidates multipleFuture
s into one, by listening to individualFuture
s and producing an aggregated result (success/failure) when allFuture
s have completed.