xstream-upon-stop
v1.0.0
Published
An xstream operator to run a function at the stop of a stream
Downloads
2
Readme
xstream-upon-stop
pnpm install --save xstream-upon-stop
An xstream operator to run an imperative function upon the lifecycle-stop of the stream
usage
import fromDiagram from 'xstream/extra/fromDiagram'
import uponStop from 'xstream-upon-stop'
let is_complete = false
const stream = fromDiagram('1----2--3--4----5|')
.compose(uponStop(() => {
console.log('stopping')
}))
stream.addListener({
next: i => console.log(i),
error: err => console.error(err),
complete: () => console.log('completed')
})
> 1 (after 60 ms)
> 2 (after 160 ms)
> 3 (after 220 ms)
> 4 (after 280 ms)
> 5 (after 380 ms)
> completed
> stopping
License
MIT