Convert an async iterator/iterable to a readable stream
npm install async-iterator-to-stream   
> Convert an async iterator/iterable to a readable stream
Even though this library is dedicated to async iterators, it is fully
compatible with synchronous ones.
Furthermore, generators can be used to create readable stream factories!
Installation of the npm package:
```
> npm install --save async-iterator-to-stream
`js
const asyncIteratorToStream = require("async-iterator-to-stream");
// sync/async iterators
asyncIteratorToStream(new Set(["foo", "bar"]).values()).pipe(output);
// sync/async iterables
asyncIteratorToStream.obj([1, 2, 3]).pipe(output);
// if you pass a sync/async generator, it will return a factory instead of a
// stream
const createRangeStream = asyncIteratorToStream.obj(function*(n) {
for (let i = 0; i < n; ++i) {
yield i;
}
});
createRangeStream(10).pipe(output);
`
Let's implement a simpler fs.createReadStream to illustrate the usage of this
library.
`js
const asyncIteratorToStream = require("async-iterator-to-stream");
// promisified fs
const fs = require("mz/fs");
const createReadStream = asyncIteratorToStream(async function*(file) {
const fd = await fs.open(file, "r");
try {
let size = yield;
while (true) {
const buf = Buffer.alloc(size);
const [n] = await fs.read(fd, buf, 0, size, null);
if (n < size) {
yield buf.slice(0, n);
return;
}
size = yield buf;
}
} finally {
await fs.close(fd);
}
});
createReadStream("foo.txt").pipe(process.stdout);
`
> If your environment does not support async generators, you may use a sync
> generator instead and yield promises to wait for them.
`Install dependencies
> npm
Contributions are _very_ welcomed, either on the documentation or on
the code.
You may:
- report any issue
you've encountered;
- fork and create a pull request.
ISC © Julien Fontanet