@@ -835,6 +835,8 @@ class TcpConnection extends ConnectionInterface
}
if ($this->_sendBuffer === '') {
$this->destroy();
+ } else {
+ $this->pauseRecv();