browser-readablestream-to-it

Turns a browser readable stream into an async iterator

Install

$ npm install --save browser-readablestream-to-it

Usage

const toIt = require('browser-readablestream-to-it')
const all = require('it-all')

const content = [0, 1, 2, 3, 4]

const stream = new ReadableStream({
  start(controller) {
    for (let i = 0; i < content.length; i++) {
      controller.enqueue(content[i])
    }

    controller.close()
  }
})

const arr = await all(toIt(stream))

console.info(arr) // 0, 1, 2, 3, 4

preventCancel

By default a readable stream will have .cancel called on it once it has ended or reading has stopped prematurely.

To prevent this behaviour, pass preventCancel: true as an option:

const arr = await all(toIt(stream, { preventCancel: true }))

console.info(arr) // 0, 1, 2, 3, 4