callbag-take-while
Callbag operator which emits values emitted by the source as long as each value satisfies the given predicate, and then completes as soon as predicate is not satisfied. Call lastly function when callbag is over. This operator forked from: Andarist: takeWhile
Example
// log: 1, 2, 3, 4, "failed on test: 5"