Class PromiseAggregator<V, F extends Future<V>>

java.lang.Object

io.netty.util.concurrent.PromiseAggregator<V,F>

Type Parameters:

V - the type of value returned by the Future

F - the type of Future

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

Constructors

Constructor	Description
PromiseAggregator(Promise<Void> aggregatePromise)	Deprecated. See PromiseAggregator(Promise, boolean).
PromiseAggregator(Promise<Void> aggregatePromise, boolean failPending)	Deprecated. Creates a new instance.

Method Summary

Modifier and Type	Method	Description
final PromiseAggregator<V,F>	add(Promise<V>... promises)	Deprecated. Add the given Promises to the aggregator.
void	operationComplete(F future)	Deprecated. Invoked when the operation associated with the Future has been completed.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PromiseAggregator

public PromiseAggregator(Promise<Void> aggregatePromise,
 boolean failPending)

Deprecated.

Creates a new instance.

Parameters:

aggregatePromise - the Promise to notify

failPending - true to fail pending promises, false to leave them unaffected

PromiseAggregator

public PromiseAggregator(Promise<Void> aggregatePromise)

Deprecated.

See PromiseAggregator(Promise, boolean). Defaults failPending to true.

Method Details

add

@SafeVarargs
public final PromiseAggregator<V,F> add(Promise<V>... promises)

Deprecated.

Add the given Promises to the aggregator.

operationComplete

public void operationComplete(F future)
                       throws Exception

Deprecated.

Description copied from interface: GenericFutureListener

Invoked when the operation associated with the Future has been completed.

Specified by:

operationComplete in interface GenericFutureListener<V>

Parameters:

future - the source Future which called this callback

Throws:

Exception