io.netty.util.concurrent

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

java.lang.Object

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

所有已实现的接口:

GenericFutureListener<F>, java.util.EventListener

直接已知子类:

ChannelPromiseAggregator

已过时。

Use PromiseCombiner 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 java.lang.Object
implements GenericFutureListener<F>

构造器概要

构造器

构造器和说明
PromiseAggregator(Promise<java.lang.Void> aggregatePromise) 已过时。 See PromiseAggregator(Promise, boolean).
PromiseAggregator(Promise<java.lang.Void> aggregatePromise, boolean failPending) 已过时。 Creates a new instance.

方法概要

方法

限定符和类型	方法和说明
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.

从类继承的方法 java.lang.Object

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

构造器详细资料

PromiseAggregator

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

已过时。

Creates a new instance.

参数:

aggregatePromise - the Promise to notify

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

PromiseAggregator

public PromiseAggregator(Promise<java.lang.Void> aggregatePromise)

已过时。

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

方法详细资料

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 java.lang.Exception

已过时。

从接口复制的说明: GenericFutureListener

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

指定者:

operationComplete 在接口中 GenericFutureListener<F extends Future<V>>

参数:

future - the source Future which called this callback

抛出:

java.lang.Exception