diff --git a/src/main/java/org/jboss/netty/channel/socket/nio/NioWorker.java b/src/main/java/org/jboss/netty/channel/socket/nio/NioWorker.java index 395e191326..03455cacd1 100644 --- a/src/main/java/org/jboss/netty/channel/socket/nio/NioWorker.java +++ b/src/main/java/org/jboss/netty/channel/socket/nio/NioWorker.java @@ -370,6 +370,7 @@ class NioWorker implements Runnable { if (internalWriteBuffer.isEmpty()) { channel.writeBuffer.drainTo(internalWriteBuffer); } + evt = channel.currentWriteEvent; for (;;) { if (evt == null) {