most-async-iterable
v1.0.1
Published
Create Most.js Streams from async iterables
Downloads
219
Maintainers
Readme
most-async-iterable
Create Most.js Streams from async iterables
Install
npm install most-async-iterable
You may need to polyfill Symbol.asyncIterator
:
npm install core-js
import '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)