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.
Use
PromiseCombiner(EventExecutor).
GenericFutureListener implementation which consolidates multiple Futures
into one, by listening to individual Futures and producing an aggregated result
(success/failure) when all Futures have completed.-
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 givenPromises to the aggregator.voidoperationComplete(F future) Deprecated.Invoked when the operation associated with theFuturehas been completed.
-
Constructor Details
-
PromiseAggregator
-
PromiseAggregator
Deprecated.SeePromiseAggregator(Promise, boolean). DefaultsfailPendingto true.
-
-
Method Details
-
add
Deprecated.Add the givenPromises to the aggregator. -
operationComplete
Deprecated.Description copied from interface:GenericFutureListenerInvoked when the operation associated with theFuturehas been completed.- Specified by:
operationCompletein interfaceGenericFutureListener<V>- Parameters:
future- the sourceFuturewhich called this callback- Throws:
Exception
-