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

@basic-streams/ap

1.0.0 • Public • Published

@basic-streams/ap

ap<T, U>(streamfStream<(x: T) => U>, streamvStream<T>)Stream<U>

Creates a stream that will contain values created by applying the latest function from streamf to the latest value from streamv every time one of them updates.

import ofMany from "@basic-streams/of-many"
import ap from "@basic-streams/ap"
 
const streamf = ofMany([x => x + 2, x => x - 2], 10000)
const streamv = ofMany([1, 2, 3], 8000)
 
const result = ap(streamf, streamv)
 
result(x => {
  console.log(x)
})
 
// > 3
// > 4
// > 0
// > 1
 
//               x => x + 2   x => x - 2
// streamf: _________._________.
// streamv: _______1_______2_______3
// result:  _________3_____4___0___1

Install

npm i @basic-streams/ap

DownloadsWeekly Downloads

17

Version

1.0.0

License

MIT

Unpacked Size

4.88 kB

Total Files

8

Last publish

Collaborators

  • avatar