我对 Buffers 和 ReadableStreams 还很陌生，所以也许这是一个愚蠢的问题。我有一个将 a 作为输入的库ReadableStream，但我的输入只是一个 base64 格式的图像。我可以Buffer像这样转换我拥有的数据：
var img = new Buffer(img_string, 'base64');
但我不知道如何将其转换为 aReadableStream或将Buffer我获得的转换为ReadableStream.
有没有办法做到这一点，还是我试图实现不可能的目标？
谢谢。
对于 nodejs 10.17.0 及更高版本：
const { Readable } = require('stream');
const stream = Readable.from(myBuffer.toString());
像这样的东西......
import { Readable } from 'stream'
const buffer = new Buffer(img_string, 'base64')
const readable = new Readable()
readable._read = () => {} // _read is required but you can noop it
readable.push(buffer)
readable.push(null)
readable.pipe(consumer) // consume the stream
在一般过程中，可读流的_read函数应该从底层源收集数据，并push逐步确保您不会在需要之前将大量源收集到内存中。
在这种情况下，虽然您已经在内存中拥有源代码，但_read不是必需的。
推送整个缓冲区只是将其包装在可读流 api 中。
Node Stream Buffer显然是为测试而设计的；无法避免延迟使其成为生产使用的糟糕选择。
Gabriel Llamas在这个答案中建议使用流化器： How to wrap a buffer as a stream2 Readable stream?
您可以使用Node Stream Buffers创建一个 ReadableStream，如下所示：
// Initialize stream
var myReadableStreamBuffer = new streamBuffers.ReadableStreamBuffer({
frequency: 10, // in milliseconds.
chunkSize: 2048 // in bytes.
});
// With a buffer
myReadableStreamBuffer.put(aBuffer);
// Or with a string
myReadableStreamBuffer.put("A String", "utf8");
频率不能为 0，因此这会引入一定的延迟。
您不需要为单个文件添加整个 npm lib。我将它重构为typescript：
import { Readable, ReadableOptions } from "stream";
export class MultiStream extends Readable {
_object: any;
constructor(object: any, options: ReadableOptions) {
super(object instanceof Buffer || typeof object === "string" ? options : { objectMode: true });
this._object = object;
}
_read = () => {
this.push(this._object);
this._object = null;
};
}
基于节点流化器（如上所述的最佳选择）。