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.

callbag-concat-with

👜 Callbag operator that emits items given it as arguments after it finishes emitting items emitted by source.

callbag-of

👜 Callbag source factory that emits values specified as arguments.

callbag-defer

👜 Callbag which creates a source from a given factory when sink subscribes.

callbag-to-promise

👜 Callbag operator which converts source to a promise containing last emitted value.