pumpify
Combine an array of streams into a single duplex stream using pump and duplexify. If one of the streams closes/errors all streams in the pipeline will be destroyed.
Usage
Pass the streams you want to pipe together to pumpify pipeline = pumpify(s1, s2, s3, ...)
. pipeline
is a duplex stream that writes to the first streams and reads from the last one. Streams are piped together using pump so if one of them closes all streams will be destroyed.
If you are pumping object streams together use pipeline = pumpify.obj(s1, s2, ...)
. Call pipeline.destroy()
to destroy the pipeline (including the streams passed to pumpify).
Using setPipeline(s1, s2, ...)
setPipeline(s1, s2, ...)
Similar to duplexify you can also define the pipeline asynchronously using setPipeline(s1, s2, ...)
License
MIT
Related
pumpify
is part of the mississippi stream utility collection which includes more useful stream modules similar to this one.
Last updated