Comparing version 2.0.3-1 to 2.0.3-2
@@ -45,3 +45,3 @@ "use strict"; | ||
const { readFile, existsSync } = require("fs"); | ||
const VERSION = "2.0.3-1"; | ||
const VERSION = "2.0.3-2"; | ||
const LANG = "nats.js"; | ||
@@ -119,3 +119,4 @@ class NodeTransport { | ||
this.socket.on("data", (frame) => { | ||
this.yields.push(frame); | ||
const count = frame.byteLength; | ||
this.yields.push(frame.slice(0, count)); | ||
const t = nats_base_client_1.DataBuffer.concat(...this.yields); | ||
@@ -252,3 +253,4 @@ const pm = nats_base_client_1.extractProtocolMessage(t); | ||
this.socket.on("data", (frame) => { | ||
this.yields.push(frame); | ||
const count = frame.byteLength; | ||
this.yields.push(frame.slice(0, count)); | ||
return this.signal.resolve(); | ||
@@ -255,0 +257,0 @@ }); |
{ | ||
"name": "nats", | ||
"version": "2.0.3-1", | ||
"version": "2.0.3-2", | ||
"description": "Node.js client for NATS, a lightweight, high-performance cloud native messaging system", | ||
@@ -63,3 +63,3 @@ "keywords": [ | ||
"devDependencies": { | ||
"@types/node": "^14.14.25", | ||
"@types/node": "^14.14.34", | ||
"ava": "^3.15.0", | ||
@@ -66,0 +66,0 @@ "minimist": "^1.2.5", |
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
532582
8914