[FIX] added guard to see if it fixes #560 (#564)

* [FIX] added guard to see if it fixes #560 * bump version
nats-io · Mar 11, 2023 · cb98efa · cb98efa
1 parent e14312f
commit cb98efa
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 6 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "nats",
-  "version": "2.13.0",
+  "version": "2.13.1",
   "description": "Node.js client for NATS, a lightweight, high-performance cloud native messaging system",
   "keywords": [
     "nats",

diff --git a/src/node_transport.ts b/src/node_transport.ts
@@ -34,7 +34,7 @@ const { resolve } = require("path");
 const { readFile, existsSync } = require("fs");
 const dns = require("dns");
 
-const VERSION = "2.13.0";
+const VERSION = "2.13.1";
 const LANG = "nats.js";
 
 export class NodeTransport implements Transport {
@@ -270,8 +270,11 @@ export class NodeTransport implements Transport {
     });
 
     this.socket.on("end", () => {
-      this.socket.write(new Uint8Array(0), () => {
-        this.socket.end();
+      if(this.socket?.destroyed) {
+        return;
+      }
+      this.socket?.write(new Uint8Array(0), () => {
+        this.socket?.end();
       });
     });