$ npm install to-through
Wrap a Readable
stream in a Transform
stream.
var { Readable } = require('streamx');
var concat = require('concat-stream');
var toThrough = require('to-through');
var readable = Readable.from([' ', 'hello', ' ', 'world']);
// Can be used as a Readable or Transform
var maybeTransform = toThrough(readable);
Readable.from(['hi', ' ', 'there', ','])
.pipe(maybeTransform)
.pipe(
concat(function (result) {
// result === 'hi there, hello world'
})
);
toThrough(readableStream)
Takes a Readable
stream as the only argument and returns a Transform
stream wrapper. Any data
piped into the Transform
stream is piped passed along before any data from the wrapped Readable
is injected into the stream.
MIT
© 2010 - cnpmjs.org x YWFE | Home | YWFE