pumpcat pipes streams together and concatenates strings or binary data and calls a callback with the result
pumpcat = pump + (concatination using bl)
npm install pumpcat
All the problems that pump solves with added functionality of concatinating the buffer for you and let you handle the error.
Simply pass the streams you want to pipe together to pumpstream and add a callback
const pumpcat = require('pumpcat')
const { Readable, PassThrough } = require('stream')
const source = new Readable
const dest = new PassThrough()
pumpcat(source, dest, function(err, collection) {
if (err) console.log('oops error occured', err)
console.log('here is collection of data you wanted', collection)
})
setTimeout(function() {
dest.destroy() // when dest is closed pumpcat will destroy source
}, 1000)You can use pumpcat to pipe more than two streams together as well
var transform = someTransformStream()
pumpcat(source, transform, anotherTransform, dest, function(err, collection) {
if (!err) console.log('got collection. YAY!')
})If source, transform, anotherTransform or dest closes all of them will be destroyed.
MIT