概述合并与串联适用于多段数据顺序输出。本文提供最小串联实现,兼容背压机制。串联实现function concatStreams(streams) {
return new ReadableStream({
async pull(controller) {
while (streams.length) {
const reader = streams[0].getReader();
while (true) {
const { value, done } = await reader.read();
if (done) break;
controller.enqueue(value);
return; // 将控制权交给背压
}
streams.shift();
}
controller.close();
}
});
}

发表评论 取消回复