xstream-upon-start

pnpm install --save xstream-upon-start

An xstream operator to run an imperative function upon the lifecycle-start of the stream

usage

import fromDiagram from 'xstream/extra/fromDiagram'
import uponStart from 'xstream-upon-start'

let is_complete = false
const stream = fromDiagram('1----2--3--4----5|')
  .compose(uponStart(() => {
    console.log('starting')
  }))

stream.addListener({
  next: i => console.log(i),
  error: err => console.error(err),
  complete: () => console.log('completed')
})

> starting
> 1  (after 60 ms)
> 2  (after 160 ms)
> 3  (after 220 ms)
> 4  (after 280 ms)
> 5  (after 380 ms)
> completed

License

MIT