Learn about our RFC process, Open RFC meetings & more.Join in the discussion! »

@basic-streams/chain

1.0.0 • Public • Published

@basic-streams/chain

chain<T, U>(fn: (x: T) => Stream<U>, streamStream<T>)Stream<U>

Creates a stream containing all values from all streams created by applying the given function fn to each value in the given stream.

import ofMany from "@basic-streams/of-many"
import chain from "@basic-streams/chain"
 
const stream = ofMany([1, 2], 10000)
const fn = x => ofMany([x, x, x], 7000)
 
const result = chain(fn, stream)
 
result(x => {
  console.log(x)
})
 
// > 1
// > 1
// > 2
// > 1
// > 2
// > 2
 
// stream: _________1_________2
// fn(1):            ______1______1______1
// fn(2):                      ______2______2______2
// result: ________________1______1__2___1__2______2

Install

npm i @basic-streams/chain

DownloadsWeekly Downloads

2

Version

1.0.0

License

MIT

Unpacked Size

4.65 kB

Total Files

8

Last publish

Collaborators

  • avatar