most-async-iterable
Create Most.js Streams from async iterables
Install
npm install most-async-iterableYou may need to polyfill Symbol.asyncIterator:
npm install core-jsimport 'core-js/modules/es7.symbol.async-iterator'API
fromAsyncIterable(asyncIterable)
Create a stream from an async iterable object.
import { fromAsyncIterable } from 'most-async-iterable'
async function sleep (duration) {
return new Promise(function (resolve) {
setTimeout(resolve, duration)
})
}
async function * numbers () {
for (var i = 0; ; ++i) {
await sleep(1000)
yield i
}
}
// Create an infinite stream of numbers
var stream = fromAsyncIterable(numbers())
// Limit the stream to the first 3 numbers
stream.take(3)
.observe(x => console.log(x))
// Logs
// 0 (after 1 second)
// 1 (after 1 more second)
// 2 (after 1 more second)asyncGenerate(generator, ...args)
Build a stream by running an async generator.
Note that unlike most.generate, this will not unwrap promises yielded by the generator. Use yield await ... instead.
import { asyncGenerate } from 'most-async-iterable'
async function sleep (duration) {
return new Promise(function (resolve) {
setTimeout(resolve, duration)
})
}
async function * countdown (delay, start) {
for (let i = start; i > 0; --i) {
await sleep(delay)
yield i
}
}
asyncGenerate(countdown, 1000, 3)
.observe(x => console.log(x))
// Logs
// 3 (after 1 second)
// 2 (after 1 more second)
// 1 (after 1 more second)
