Collect a readable stream's output and errors.
Give it a readable stream and a function and it will call latter with the potential error and a smart representation of the data the stream emitted.
import collect from 'collect-stream';
collect(stringStream, (err, data) => {
console.log(data); // one string
});
collect(bufferStream, (err, data) => {
console.log(data); // one buffer
});
collect(objectStream, (err, data) => {
console.log(data); // an array of objects
});Give it options and it will pass them to concat-stream.
import collect from 'collect-stream';
opts = {encoding: "object"}
collect(opts, unknownStream, (err, data) => {
console.log(data) // forced to be an array of objects
});$ npm install collect-streamMIT