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(); })();