streamiterator

streamiterator

Converts ReadableStream into AsyncIterator.

Using

With this module you can iterate over a stream with a plain loop:

import streamIterator from "streamiterator"
// or
// const streamIterator = require("streamiterator")

async function DoIt(stream) {
	for await (const value of streamIterator(stream)) {
		console.log(`Read: ${value}`)
	}
}

Yu can use here any stream you are able to get from nodejs - file streams like fs.createReadableStream(...), http responses and so on.

As of August, 2017 you need smth like either babel or node.js 8.4.0 or higher with --harmony_async_iteration switch to be able to use for await operator.

Of course, you can iterate without for await, though it is not so nice as using syntactic suger:

import streamIterator from "streamiterator"

async function DoIt(stream) {
	for (let done, value, iterator = streamIterator(stream); {done, value} = await iterator.next(), !done;) {
		console.log(`Read: ${value}`)
	}
}

If the stream emits an error, it will be thrown while looping. Wrap your loop in try..catch to deal with it.

If eventually streams will support async iteration natively then this module will just redirect iteration to that native mechanism. No overhead will be added.

Polyfill

But if you believe that writing streamIterator(...) everywhere is a bullshit and in your world streams have to be iterable from the scratch right now, then you can import streamiterator/polyfill in the root of your project and iterate just on streams:

import "streamiterator/polyfill"
import fs from "fs"

async function DoIt() {
	for await (const data of fs.createReadableStream("./data.txt")) {
		console.log(data)
	}
}

Note that you don't need to import streamiterator/polyfill in every file of your project. Just in the main.js or similar.

Contributing

Please contribute! All contributions are greatly appreciated no matter how small or large the contribution is. Whether it's a small grammar fix in the README, a huge bug fix, or just an issue report, you will be recognized as a 'Contributor' to this project.

Please, feel free to open an issue if you have any question.