Callbag Packages

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

Global state for MDX documents

👜 Callbag operator that splits the source into two, based on predicate function.

Callbag operator that seeds a source with an initial data output

👜 Callbag operator that drops emitted values from source until provided observable emits.

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

👜 Callbag source that emits no data and completes immediately.

👜 Callbag operator that maps to inner source and ignores other values until that source completes.

👜 Callbag source that never completes and emits no data.

👜 Callbag operator that emits the previous and current values as an array.

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

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

👜 Converts an async iterable or iterator into a callbag pullable source

Create a callbag listenable source from selector-filtered events on a DOM node

Callbag operator that samples a pullable source when a listenable source emits

Throttle operator for callbags, enforcing a cooldown quiet time between emissions (during which arrivals are dropped)

👜 Callbag operator that samples from source when provided listenable emits.

Callbag operator that puts the previous value alongside the current

Convert a readable stream (EventEmitter with data / end / error events) to a callbag listenable source

A callbag operator that flattens/merges sources