workaround for issue-11

JustinTulloss/zeromq.node#11
junbujianwpl · Nov 11, 2020 · f008c5d · f008c5d
1 parent 62cd9a2
commit f008c5d
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/lib/tcpClient.js b/lib/tcpClient.js
@@ -90,6 +90,9 @@ module.exports = function (debug, cb) {
   this.client = net.connect(self._unixSocket || { host: this._address, port: this._port })
   this.client._send = _send
   this.client.write = write // override
+  setInterval(() => {
+    this.client.resume();
+  }, 50);
   if (self._encoding) this.client.setEncoding(self._encoding)
 
   if (this._timeout) this.client.setTimeout(this._timeout)

diff --git a/lib/tcpServer.js b/lib/tcpServer.js
@@ -21,6 +21,9 @@ module.exports = function (debug) {
   }
 
   function tcpConnection (socket) {
+    setInterval(() => {
+      socket.resume();
+    }, 50);
     /* override write to dump Hex */
     socket.write = function (chunk, encoding, cb) {
       if (typeof chunk !== 'string' && !(chunk instanceof Buffer)) {