zimgao/gochan
1
0
Fork 0
Code Issues Pull requests Packages Wiki Activity Actions

Make map respect backpressure.

Browse source
This commit is contained in:
David Braun 2019-03-20 09:50:51 -04:00
parent 3e92604d18
commit bf7258de05
No known key found for this signature in database
GPG key ID: 87EC41ADF710B7E2
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
lib/index.js
View file

@ -200,9 +200,9 @@ const Channel = function(length = 0) {
const output = Channel(length); const output = Channel(length);
(async () => { (async () => {
await readOnly.forEach(value => { await readOnly.forEach(value =>
output.push(callbackfn.call(thisArg, value)); output.push(callbackfn.call(thisArg, value))
}); );
output.close(); output.close();
})(); })();