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.Runnablepublic void operationComplete(ChannelFuture future) throws java.lang.Exception
GenericFutureListenerFuture has been completed.operationComplete in interface GenericFutureListener<ChannelFuture>future - the source Future which called this callbackjava.lang.Exception