Callbag Packages

👜 Callbag operator that emits the single value at the specified index.

Expressions with callbags

Callbag operator that conditionally lets data pass through

Callbag operator that emits only the first value emitted by the source Callbag that meets some condition given a predicate function. Works for listenable and pullable sources.

Emit the first value

A callbag operator that maps items to sources and flattens them lazily

Convert a Promise to a callbag listenable source

👜 Callbag source factory

A implementation of the interval operator that emits immediately

Callbag puller sink that iterates over a pullable source

Emit the last value emitted from source on completion.

👜 Callbag operator that accumulates results using a feedback loop that emits one value and feeds back another to be used in the next iteration.

Lossless throttle operator for callbags, enforcing a cooldown quiet time between emissions and queuing arrivals

Callbag operator that applies a transformation, which may be dot-notated path, on data passing through it

Callbag operator that changes data passing through it to a fixed value

Callbag operator that merges all items a source of sources into a single output source

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

Callbag operator version of merge

Like callbag-interval, but can be paused and resumed upon pulling

👜 Callbag operator that maps to object properties.