it-to-stream

Convert streaming iterables to Node.js streams

Install

1npm i it-to-stream

Usage

1const toStream = require('it-to-stream')

Convert source iterable to readable stream

1// A streaming iterable "source" is just an (async) iterable
2const source = (async function * () {
3  for (const value of [1, 2, 3, 4]) yield Buffer.from(value.toString())
4})()
5
6const readable = toStream.readable(source)
7
8// Now we have a readable stream, we can consume it by
9readable.on('data', console.log)
10// or
11readable.pipe(writable)
12// or
13pipeline(readable, writable, err => console.log(err || 'done'))

Convert sink iterable to writable stream

1// A streaming iterable "sink" is an (async) function that takes a "source"
2// and consumes it.
3const sink = async source => {
4  for await (const chunk of source) {
5    console.log(chunk.toString())
6  }
7}
8
9const writable = toStream.writable(sink)
10
11// Now we have a writable stream, we can pipe to it
12fs.createReadStream('/path/to/file').pipe(writable)

Convert transform iterable to transform stream

1// A streaming iterable "transform" is a function that takes a "source" and
2// returns a "source".
3const transform = source => (async function * () {
4  for await (const chunk of source) {
5    // Replace all space characters with dashes
6    yield Buffer.from(chunk.toString().replace(/ /g, '-'))
7  }
8})()
9
10const transform = toStream.transform(transform)
11
12// Now we have a transform stream, we can pipe to and from it
13fs.createReadStream('/path/to/file')
14  .pipe(transform)
15  .pipe(fs.createWriteStream('/path/to/file2'))

API

1const toStream = require('it-to-stream')

toStream.readable(source, [options]): Readable

Convert a source iterable to a Readable stream.

options are passed directly to the Readable constructor.

toStream.writable(sink, [options]): Writable

Convert a sink iterable to a Writable stream.

options are passed directly to the Writable constructor.

toStream.transform(transform, [options]): Transform

Convert a transform iterable to a Transform stream.

options are passed directly to the Transform constructor.

toStream.duplex(duplex, [options]): Duplex

Convert a duplex iterable to a Duplex stream.

options are passed directly to the Duplex constructor.

Related

• stream-to-it Convert Node.js streams to streaming iterables
• it-pipe Utility to "pipe" async iterables together

Contribute

Feel free to dive in! Open an issue or submit PRs.

License

MIT © Alan Shaw