Comparing version 2.0.0-201 to 2.0.0-202
@@ -16,3 +16,3 @@ #!/usr/bin/env node | ||
csvheader: false, | ||
pending: 1024*32 | ||
pending: 1024 * 32, | ||
}; | ||
@@ -59,3 +59,5 @@ | ||
for (let i = 0; i < iters; i++) { | ||
const nc = await connect({ servers: server, debug: argv.debug, pending: argv.pending }); | ||
const nc = await connect( | ||
{ servers: server, debug: argv.debug, pending: argv.pending }, | ||
); | ||
const opts = { | ||
@@ -137,4 +139,1 @@ msgs: count, | ||
}); | ||
@@ -31,3 +31,3 @@ "use strict"; | ||
const { readFile, existsSync } = require("fs"); | ||
const VERSION = "2.0.0-201"; | ||
const VERSION = "2.0.0-202"; | ||
const LANG = "nats.js"; | ||
@@ -205,2 +205,7 @@ class NodeTransport { | ||
}); | ||
tlsSocket.on("secureConnect", () => { | ||
if (!tlsSocket.authorized) { | ||
throw tlsSocket.authorizationError; | ||
} | ||
}); | ||
tlsSocket.on("close", () => { | ||
@@ -227,4 +232,8 @@ d.reject(tlsError); | ||
}); | ||
this.socket.on("end", () => { | ||
this.socket.write(new Uint8Array(0), () => { | ||
this.socket.end(); | ||
}); | ||
}); | ||
this.socket.on("close", () => { | ||
// if socket notified a close, any write will fail | ||
this.socket = undefined; | ||
@@ -231,0 +240,0 @@ this._closed(connError, false); |
{ | ||
"name": "nats", | ||
"version": "2.0.0-201", | ||
"version": "2.0.0-202", | ||
"description": "Node.js client for NATS, a lightweight, high-performance cloud native messaging system", | ||
@@ -5,0 +5,0 @@ "keywords": [ |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
315575
4742
2