创建 ReadableStream
的朴素方法是从 Buffer
使用 ReadableStream
构造函数,并将整个数组作为单个块进行排队。对于较大的缓冲区,这可能是不合适的,因为这种方法不会以较小的块“流式传输”数据。
const buf = Buffer.from("hello world");
const stream = new ReadableStream({
start(controller) {
controller.enqueue(buf);
controller.close();
},
});
要以较小的块流式传输数据,首先从 Buffer
创建一个 Blob
实例。然后使用 Blob.stream()
方法创建一个 ReadableStream
,该流以指定大小的块流式传输数据。
const buf = Buffer.from("hello world");
const blob = new Blob([buf]);
const stream = blob.stream();
可以通过将数字传递给 .stream()
方法来设置块大小。
const buf = Buffer.from("hello world");
const blob = new Blob([buf]);
// set chunk size of 1024 bytes
const stream = blob.stream(1024);
有关使用 Bun 处理二进制数据的完整文档,请参阅 文档 > API > 二进制数据。