概述合并与串联适用于多段数据顺序输出。本文提供最小串联实现,兼容背压机制。串联实现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();

}

});

}

点赞(0) 打赏

评论列表 共有 0 条评论

暂无评论
立即
投稿

微信公众账号

微信扫一扫加关注

发表
评论
返回
顶部