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

Rewrite map.

Browse source
This commit is contained in:
David 2021-02-08 16:34:29 -06:00
parent ed06cb080e
commit 71da094422
1 changed files with 4 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

17
lib/index.js
View file

@ -182,19 +182,10 @@ const Channel = function(length = 0) {
join: async (separator) => (await readOnly.values()).join(separator), join: async (separator) => (await readOnly.values()).join(separator),
map: (callbackfn, thisArg) => { map: (callbackfn, thisArg) =>
const output = Channel(); readOnly.flatMap((value) =>
Channel.of(callbackfn.call(thisArg, value))
(async () => { ),
await readOnly.forEach((value) =>
output.push(callbackfn.call(thisArg, value))
);
await output.close();
})();
return output;
},
readOnly: () => readOnly, readOnly: () => readOnly,