From bf7258de051bc11dde9a448f29251291080108a2 Mon Sep 17 00:00:00 2001 From: David Braun Date: Wed, 20 Mar 2019 09:50:51 -0400 Subject: [PATCH] Make `map` respect backpressure. --- lib/index.js | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/lib/index.js b/lib/index.js index af19e1a..a5d88a5 100644 --- a/lib/index.js +++ b/lib/index.js @@ -200,9 +200,9 @@ const Channel = function(length = 0) { const output = Channel(length); (async () => { - await readOnly.forEach(value => { - output.push(callbackfn.call(thisArg, value)); - }); + await readOnly.forEach(value => + output.push(callbackfn.call(thisArg, value)) + ); output.close(); })();