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)
.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.
-
-
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 givenPromise
s to the aggregator.void
operationComplete(F future)
Deprecated.Invoked when the operation associated with theFuture
has been completed.
-
-
-
Constructor Detail
-
PromiseAggregator
public PromiseAggregator(Promise<java.lang.Void> aggregatePromise, boolean failPending)
Deprecated.Creates a new instance.- Parameters:
aggregatePromise
- thePromise
to notifyfailPending
-true
to fail pending promises, false to leave them unaffected
-
PromiseAggregator
public PromiseAggregator(Promise<java.lang.Void> aggregatePromise)
Deprecated.SeePromiseAggregator(Promise, boolean)
. DefaultsfailPending
to true.
-
-
Method Detail
-
add
@SafeVarargs public final PromiseAggregator<V,F> add(Promise<V>... promises)
Deprecated.Add the givenPromise
s to the aggregator.
-
operationComplete
public void operationComplete(F future) throws java.lang.Exception
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:
java.lang.Exception
-
-