diff --git a/src/main/java/org/jboss/netty/channel/socket/http/HttpTunnelingClientSocketChannel.java b/src/main/java/org/jboss/netty/channel/socket/http/HttpTunnelingClientSocketChannel.java index 068d0b70be..5f2a32dfc4 100644 --- a/src/main/java/org/jboss/netty/channel/socket/http/HttpTunnelingClientSocketChannel.java +++ b/src/main/java/org/jboss/netty/channel/socket/http/HttpTunnelingClientSocketChannel.java @@ -257,6 +257,9 @@ class HttpTunnelingClientSocketChannel extends AbstractChannel public void operationComplete(ChannelFuture f) { if (f.isSuccess()) { future.setSuccess(); + if (size != 0) { + fireWriteComplete(HttpTunnelingClientSocketChannel.this, size); + } } else { future.setFailure(f.getCause()); }