Propagate channelWritabilityChanged() through the pipeline after flushing. Related to [#1861]

This commit is contained in:
Norman Maurer 2013-09-24 14:05:25 +02:00
parent f35ba4f80f
commit 52660dfcfa

View File

@ -129,11 +129,6 @@ public class ChunkedWriteHandler
}
}
@Override
public void read(ChannelHandlerContext ctx) {
ctx.read();
}
@Override
public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
queue.add(new PendingWrite(msg, promise));
@ -159,6 +154,7 @@ public class ChunkedWriteHandler
// channel is writable again try to continue flushing
doFlush(ctx);
}
ctx.fireChannelWritabilityChanged();
}
private void discard(Throwable cause) {