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>,java.util.EventListener
- Direct Known Subclasses:
ChannelPromiseAggregator
@Deprecated public class PromiseAggregator<V,F extends Future<V>> extends java.lang.Object implements GenericFutureListener<F>
Deprecated.UsePromiseCombiner(EventExecutor).GenericFutureListenerimplementation which consolidates multipleFutures into one, by listening to individualFutures and producing an aggregated result (success/failure) when allFutures have completed.
-
-
Constructor Summary
Constructors Constructor Description PromiseAggregator(Promise<java.lang.Void> aggregatePromise)Deprecated.PromiseAggregator(Promise<java.lang.Void> aggregatePromise, boolean failPending)Deprecated.Creates a new instance.
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description PromiseAggregator<V,F>add(Promise<V>... promises)Deprecated.Add the givenPromises to the aggregator.voidoperationComplete(F future)Deprecated.Invoked when the operation associated with theFuturehas been completed.
-
-
-
Constructor Detail
-
PromiseAggregator
public PromiseAggregator(Promise<java.lang.Void> aggregatePromise, boolean failPending)
Deprecated.Creates a new instance.- Parameters:
aggregatePromise- thePromiseto notifyfailPending-trueto fail pending promises, false to leave them unaffected
-
PromiseAggregator
public PromiseAggregator(Promise<java.lang.Void> aggregatePromise)
Deprecated.SeePromiseAggregator(Promise, boolean). DefaultsfailPendingto true.
-
-
Method Detail
-
add
@SafeVarargs public final PromiseAggregator<V,F> add(Promise<V>... promises)
Deprecated.Add the givenPromises to the aggregator.
-
operationComplete
public void operationComplete(F future) throws java.lang.Exception
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:
java.lang.Exception
-
-