alta-listen v1.0.0

alta-go

listen for new values coming on a channel

Example

let stream = chan(5)
let a = chan()
let b = chan()

listen(a, async (v) => {
  await stream.put(v)
})

listen(b, async (v) => {
  await sleep(30)
  await stream.put(v)
})

await a.put(1)
await b.put(2)
await a.put(3)
await a.put(4)
await b.put(5)

assert.equal(await stream.take(), 1)
assert.equal(await stream.take(), 3)
assert.equal(await stream.take(), 4)
assert.equal(await stream.take(), 2)
assert.equal(await stream.take(), 5)

Install

npm install alta-listen

License

MIT