Callbag that emits the source values until a notifier Callbag emits a value - View it on GitHub