fix: Fix end() method on async write()

Rapsssito · Jun 14, 2020 · a1a0771 · a1a0771
1 parent 2418cf6
commit a1a0771
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/src/TcpSocket.js b/src/TcpSocket.js
@@ -227,9 +227,15 @@ export default class TcpSocket {
      */
     end(data, encoding) {
         if (this._destroyed) return;
-        if (data) this.write(data, encoding);
-        this._destroyed = true;
-        Sockets.end(this._id);
+        if (data) {
+            this.write(data, encoding, () => {
+                this._destroyed = true;
+                Sockets.end(this._id);
+            });
+        } else {
+            this._destroyed = true;
+            Sockets.end(this._id);
+        }
     }
 
     destroy() {