async-iterator-to-pull-stream

async-iterator-to-pull-stream

Convert a (async) iterator to a pull stream

Install

npm install async-iterator-to-pull-stream

Usage

const pull = require('pull-stream')
const toPull = require('async-iterator-to-pull-stream')

const iterator = async function * () {
  const sourceValues = [1, 2, 3, 4, 5]
  for (let i = 0; i < sourceValues.length; i++) {
    yield await new Promise(resolve => setTimeout(() => resolve(sourceValues[i])))
  }
}

pull(
  toPull(iterator()),
  pull.collect((err, values) => {
    console.log(values) // 1, 2, 3, 4, 5
  })
)

API

toPull(iterator)

Convert an async iterator into a pull stream. Returns a pull stream that can be used as a source in a pull pipeline.

Contribute

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

License

MIT © Alan Shaw