Fixed a bug where WriteCompletionEvent is not fired for HttpTunnelingClientSocketChannel
This commit is contained in:
parent
cf57e4c42b
commit
7b61bdc08f
@ -257,6 +257,9 @@ class HttpTunnelingClientSocketChannel extends AbstractChannel
|
|||||||
public void operationComplete(ChannelFuture f) {
|
public void operationComplete(ChannelFuture f) {
|
||||||
if (f.isSuccess()) {
|
if (f.isSuccess()) {
|
||||||
future.setSuccess();
|
future.setSuccess();
|
||||||
|
if (size != 0) {
|
||||||
|
fireWriteComplete(HttpTunnelingClientSocketChannel.this, size);
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
future.setFailure(f.getCause());
|
future.setFailure(f.getCause());
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user