private final class WriteTimeoutHandler.WriteTimeoutTask extends java.lang.Object implements java.lang.Runnable, ChannelFutureListener
Modifier and Type | Field and Description |
---|---|
private ChannelHandlerContext |
ctx |
(package private) WriteTimeoutHandler.WriteTimeoutTask |
next |
(package private) WriteTimeoutHandler.WriteTimeoutTask |
prev |
private ChannelPromise |
promise |
(package private) java.util.concurrent.ScheduledFuture<?> |
scheduledFuture |
CLOSE, CLOSE_ON_FAILURE, FIRE_EXCEPTION_ON_FAILURE
Constructor and Description |
---|
WriteTimeoutTask(ChannelHandlerContext ctx,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
operationComplete(ChannelFuture future)
Invoked when the operation associated with the
Future has been completed. |
void |
run() |
private final ChannelHandlerContext ctx
private final ChannelPromise promise
WriteTimeoutHandler.WriteTimeoutTask prev
WriteTimeoutHandler.WriteTimeoutTask next
java.util.concurrent.ScheduledFuture<?> scheduledFuture
WriteTimeoutTask(ChannelHandlerContext ctx, ChannelPromise promise)
public void run()
run
in interface java.lang.Runnable
public void operationComplete(ChannelFuture future) throws java.lang.Exception
GenericFutureListener
Future
has been completed.operationComplete
in interface GenericFutureListener<ChannelFuture>
future
- the source Future
which called this callbackjava.lang.Exception