CodeSky 代码之空

在工作的时候突然就有了这样一个需求，这一次正好也对本来不太熟的 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

太困了写不下去，这篇稍微水一下（逃）

参考：

http://derpturkey.com/buffer-to-stream-in-node/