pipe-streams-to-promise

Pipe an array of streams to a single promise. Captures errors on any of the streams.

Downloads in past

Stats

StarsIssuesVersionUpdatedCreatedSize
pipe-streams-to-promise
0.2.08 years ago9 years agoMinified + gzip package size for pipe-streams-to-promise in KB

Readme

pipe-streams-to-promise
Pipes an array of streams together and returns a promise. Checks for any errors on the steams.
Heavily inspired by, and test cases taken from, epeli's promisePipe

Usage

var pipeStreams = require('pipe-streams-to-promise');

var fs = require('fs');
var zlib = require('zlib');

var gzip = zlib.createGzip();
var readStream = fs.createReadStream('myfile.txt');
var writeStream = fs.createWriteStream('myfile.txt.gz');


pipeStreams([
  readStream,
  gzip,
  writeStream
]).then(function(writeStream) {
  console.log('Done compressing.');
}).catch(function(err) {
  console.error('Ran into an error:', err);
});