Convert an observable to a callbag listenable source

debounce operator for callbag

👜 Callbag source that emits no data and completes immediately.

👜 Callbag operator which errors if source does not emit before specified duration.

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

👜 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 operator that flattens a higher-order callbag source

👜 Callbag operator which shares input stream between subscribers and emits last emitted value upon subscription.

👜 Callbag operator that emits only the last item emitted by the source.

A callbag listener sink which is also a listenable source

👜 Callbag operator which performs a side effect for every upwards emission (from sink to source), but other than that it acts as noop.

👜 Callbag source factory that immediately emits an error.

👜 Callbag operator that maps to inner source, subscribe and emit in order.

Web3 module to interact with the Ethereum nodes networking properties.

Callbag operator that limits the total amount of data sent through

👜 Callbag listenable source which emits value describing time progress (number between 0 an 1) since the subscription (using requestAnimationFrame) - useful for animations.

👜 Callbag operator that buffers the stream until another stream emits a value.

👜 Callbag listenable source which emits milliseconds elapsed since the subscription (using requestAnimationFrame) - useful for animations.

👜 Callbag source that after given duration, emit numbers in sequence every specified duration.

Callbag operator that taps the source with the given function, but otherwise is a noop