Stream 与 Buffer 的相互转换
在工作的时候突然就有了这样一个需求,这一次正好也对本来不太熟的 Stream 有了一点更加深刻的理解……(好吧本来是根本没搞清楚状况)。
Stream,中文叫做流,和我们平时充值信仰的那个 Steam 还是差了那么一点的。所谓流,是一种消费的模型,被消费完就木有了,所以如果我们需要重复使用,就得存下来,也就是把 Stream 转成别的东西——Just Like Array or Buffer。
上代码表演一下:
1function streamToBuffer(stream) {
2 return new Promise((resolve, reject) => {
3 let buffers = [];
4 stream.on('error', reject);
5 stream.on('data', (data) => buffers.push(data))
6 stream.on('end', () => resolve(Buffer.concat(buffers))
7 });
8}
9
Buffer.concat(buffers)
之后就转换为了 Buffer,可以重复使用了。
逆向转换也很简单:
1let Duplex = require('stream').Duplex;
2function bufferToStream(buffer) {
3 let stream = new Duplex();
4 stream.push(buffer);
5 stream.push(null);
6 return stream;
7}
8
太困了写不下去,这篇稍微水一下(逃)
参考:
评论 (2)
stream.on('end', () => resolve(Buffer.concat(buffers)) 这行少个括号
顶一个~