io.netty.util.concurrent

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.

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.

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

Constructor Summary

Constructors

Constructor and 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 and Description
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 java.lang.Object

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

Constructor Detail

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 Detail

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<F extends Future<V>>

Parameters:

future - the source Future which called this callback

Throws:

Exception