WritableStream 背压与队列策略实践

概述WritableStream 提供可控的背压与队列策略。本文通过自定义 sink 与策略配置实现稳定的流式写入。能力检测与自定义 WritableStreamconst supportsWS = typeof WritableStream === 'function';

function createSink(writeFn) {

return new WritableStream({

write(chunk) { return writeFn(chunk); },

close() { },

abort() { }

}, new ByteLengthQueuingStrategy({ highWaterMark: 1024 * 1024 }));

}

async function writeText(rs, sink) {

const reader = rs.getReader();

const writer = sink.getWriter();

while (true) {

const { value, done } = await reader.read();

if (done) break;

await writer.write(value);

}

await writer.close();

}