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

public class PromiseAggregator<V,F extends Future<V>>
extends Object
implements GenericFutureListener<F>

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 and Description
PromiseAggregator(Promise<Void> aggregatePromise) See PromiseAggregator(Promise, boolean).
PromiseAggregator(Promise<Void> aggregatePromise, boolean failPending) Creates a new instance.

Method Summary

Methods

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

Methods inherited from class java.lang.Object

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

Constructor Detail

PromiseAggregator

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

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)

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

Method Detail

add

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

Add the given Promises to the aggregator.

operationComplete

public void operationComplete(F future)
                       throws Exception

Description copied from interface: GenericFutureListener

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

Specified by:

operationComplete in interface GenericFutureListener<F extends Future<V>>

Parameters:

future - the source Future which called this callback

Throws:

Exception