common: createAsyncQueueFromGenerator should not read as fast as possible.

This commit is contained in:
Koushik Dutta
2024-11-06 10:07:03 -08:00
parent 5899ad866a
commit 0c641ccf6c

View File

@@ -160,7 +160,7 @@ export function createAsyncQueueFromGenerator<T>(generator: AsyncGenerator<T>) {
(async() => {
try {
for await (const i of generator) {
q.submit(i);
await q.enqueue(i);
}
}
catch (e) {