io.netty.util.concurrent

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

java.lang.Object

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

类型参数:

V - the type of value returned by the future

F - the type of future

所有已实现的接口:

GenericFutureListener<F>, java.util.EventListener

直接已知子类:

ChannelPromiseNotifier

public class PromiseNotifier<V,F extends Future<V>>
extends java.lang.Object
implements GenericFutureListener<F>

GenericFutureListener implementation which takes other Promises and notifies them on completion.

构造器概要

构造器

构造器和说明
PromiseNotifier(boolean logNotifyFailure, Promise<? super V>... promises) Create a new instance.
PromiseNotifier(Promise<? super V>... promises) Create a new instance.

方法概要

限定符和类型	方法和说明
static <V,F extends Future<V>> F	cascade(boolean logNotifyFailure, F future, Promise<? super V> promise) Link the Future and Promise such that if the Future completes the Promise will be notified.
static <V,F extends Future<V>> F	cascade(F future, Promise<? super V> promise) Link the Future and Promise such that if the Future completes the Promise will be notified.
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

构造器详细资料

PromiseNotifier

@SafeVarargs
public PromiseNotifier(Promise<? super V>... promises)

Create a new instance.

参数:

promises - the Promises to notify once this GenericFutureListener is notified.

PromiseNotifier

@SafeVarargs
public PromiseNotifier(boolean logNotifyFailure,
                                     Promise<? super V>... promises)

Create a new instance.

参数:

logNotifyFailure - true if logging should be done in case notification fails.

promises - the Promises to notify once this GenericFutureListener is notified.

方法详细资料

cascade

public static <V,F extends Future<V>> F cascade(F future,
                                                Promise<? super V> promise)

Link the Future and Promise such that if the Future completes the Promise will be notified. Cancellation is propagated both ways such that if the Future is cancelled the Promise is cancelled and vise-versa.

类型参数:

V - the type of the value.

F - the type of the Future

参数:

future - the Future which will be used to listen to for notifying the Promise.

promise - the Promise which will be notified

返回:

the passed in Future

cascade

public static <V,F extends Future<V>> F cascade(boolean logNotifyFailure,
                                                F future,
                                                Promise<? super V> promise)

Link the Future and Promise such that if the Future completes the Promise will be notified. Cancellation is propagated both ways such that if the Future is cancelled the Promise is cancelled and vise-versa.

类型参数:

V - the type of the value.

F - the type of the Future

参数:

logNotifyFailure - true if logging should be done in case notification fails.

future - the Future which will be used to listen to for notifying the Promise.

promise - the Promise which will be notified

返回:

the passed in Future

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