[#1733] Correctly pass the promise to the ctx.write(...) in AbstractTrafficShapingHandler

This commit is contained in:
Norman Maurer 2013-08-13 08:21:26 +02:00
parent f8f19d1539
commit 48eb73f9b1

View File

@ -284,7 +284,7 @@ public abstract class AbstractTrafficShapingHandler extends ChannelDuplexHandler
if (size > -1 && trafficCounter != null) { if (size > -1 && trafficCounter != null) {
trafficCounter.bytesWriteFlowControl(size); trafficCounter.bytesWriteFlowControl(size);
if (writeLimit == 0) { if (writeLimit == 0) {
ctx.write(msg); ctx.write(msg, promise);
return; return;
} }
// compute the number of ms to wait before continue with the // compute the number of ms to wait before continue with the