mirrors/bun.sh
1
0
Fork 0
mirror of https://github.com/oven-sh/bun synced 2026-02-09 10:28:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

polyfills: fix console async iterator

Browse Source
This commit is contained in:
jhmaster2000
2023-11-30 23:54:51 -03:00
parent 3550d4e94c
commit fbdbf297e1
1 changed files with 21 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
packages/bun-polyfills/src/global/console.ts
View File

@@ -9,14 +9,30 @@
// };
//}
const consoleAsyncIterChunks: string[] = [];
//? Implements: for await (const line of console) { ... }
console[Symbol.asyncIterator] = async function* () {
while (true) yield await new Promise(resolve => {
process.stdin.on('data', (data: Buffer | string) => {
const str = data.toString('utf-8').replaceAll(/[\r\n]+/g, '');
resolve(str);
if (consoleAsyncIterChunks.length) {
for (const line of [...consoleAsyncIterChunks]) {
consoleAsyncIterChunks.shift();
if (!line) continue;
yield line;
}
}
while (true) {
const p = await new Promise<string[]>(resolve => {
process.stdin.once('data', (data: Buffer | string) => {
const str = data.toString('utf-8').split(/[\r\n]+/g);
resolve(str);
});
});
});
consoleAsyncIterChunks.push(...p);
for (const line of p) {
consoleAsyncIterChunks.shift();
if (!line) continue;
yield line;
}
}
} satisfies Console[typeof Symbol.asyncIterator];
//? Implements: Bun-exclusive console function