io.netty.util.concurrent

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

java.lang.Object

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

All Implemented Interfaces:

GenericFutureListener<F>, EventListener

Direct Known Subclasses:

ChannelPromiseNotifier

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

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

Constructor Summary

Constructors

Constructor and Description
PromiseNotifier(Promise<? super V>... promises) Create a new instance.

Method Summary

Methods

Modifier and Type	Method and Description
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

PromiseNotifier

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

Create a new instance.

Parameters:

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

Method Detail

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