Comparing version 4.35.10 to 4.35.11
@@ -435,9 +435,3 @@ const scramjet = require("./"); | ||
} else { | ||
let last = true; | ||
for (const val of out) { | ||
last = ref.write(val); | ||
if (!last) await ref.whenDrained(); | ||
} | ||
return last ? null : ref.whenDrained(); | ||
await ref.whenWrote(...out); | ||
} | ||
@@ -444,0 +438,0 @@ }, |
{ | ||
"name": "scramjet", | ||
"version": "4.35.10", | ||
"version": "4.35.11", | ||
"description": "Lightweight and real-time data functional stream programming framework like event-stream, written in ES6 using async await with multi-threading and typescript support", | ||
@@ -69,7 +69,7 @@ "main": "lib/index.js", | ||
"@otris/jsdoc-tsd": "^2.0.0", | ||
"@types/node": "^14.14.16", | ||
"@types/node": "^14.14.22", | ||
"check-dts": "^0.4.1", | ||
"decache": "^4.6.0", | ||
"dmd": "^5.0.2", | ||
"eslint": "^7.16.0", | ||
"eslint": "^7.18.0", | ||
"eslint-config-scramjet": "^3.0.0", | ||
@@ -86,6 +86,6 @@ "fancy-log": "^1.3.3", | ||
"node-fetch": "^2.6.1", | ||
"nodeunit-tape-compat": "^1.3.67", | ||
"nodeunit-tape-compat": "^1.3.68", | ||
"replace-in-file": "^6.1.0", | ||
"shelljs": "^0.8.4", | ||
"tape": "^5.1.0", | ||
"tape": "^5.1.1", | ||
"through2": "^4.0.2", | ||
@@ -96,5 +96,5 @@ "vinyl": "^2.2.1" | ||
"papaparse": "^5.3.0", | ||
"rereadable-stream": "^1.4.4", | ||
"scramjet-core": "^4.31.8" | ||
"rereadable-stream": "^1.4.5", | ||
"scramjet-core": "^4.31.9" | ||
} | ||
} |
316825
3053
Updatedrereadable-stream@^1.4.5
Updatedscramjet-core@^4.31.9