⏯️ callbag-pausable
Callbag operator that allows data and talkbacks to pass through it freely until it receives a data or talkback message of PAUSE
, in which case it stops the downflow of data until it receives another data or talkback message of RESUME
.
Think of it like a valve on a pipe.
Usage
const source = source // 0 // 1 // 2 // PAUSING // RESUMING // 9 // 10 // 11 // ...
Or, as a talkback to an existing callbag (assuming callbag$
has pausable
somewhere in its pipe):
const sendTalkbackValue = { }const pause = const resume =