callbag-pause

👜 Callbag Pause is a Callbag 👜 that will convert any callbag stream into one that can be paused and resumed via an external variable.

Many thanks to André Staltz (staltz) for Callbag 👜 and to Erik Rasmussen (erikras) for callbag-pausable ⏯️

usage example

You can run the example by:

npm intall callbag-pause
npm run example

import interval from 'callbag-interval'
import subscribe from 'callbag-subscribe'
import take from 'callbag-take'
import pipe from 'callbag-pipe'
import pause from './'

let pause = false

pipe(
    interval(100),
    pausable(() => pause),
    take(6),
    subscribe(console.log)
)

setTimeout(() => {
  console.log('PAUSING')
  pause = true
}, 400)
setTimeout(() => {
  console.log('RESUMING')
  pause = false
}, 1000)

/*
Result:
    0
    1
    2
    PAUSING
    RESUMING
    9
    10
    11
*/