staltz/callbag-basics

browser-side require() the node way

tap-producing test harness for node and browsers

Callbag factory that combines data from multiple callbag sources

Callbag operator that conditionally lets data pass through

Callbag operator that flattens a higher-order callbag source

Create a callbag listenable source from events on a DOM node

Convert an observable to a callbag listenable source

Callbag operator that applies a transformation on data passing through it

Callbag factory that merges data from multiple callbag sources

Utility function for plugging callbags together in chain

Callbag operator that combines consecutive values from the same source

Callbag factory that concatenates data from multiple callbag sources

Convert an iterable or iterator to a callbag pullable source

Convert a Promise to a callbag listenable source

Callbag sink that consume both pullable and listenable sources

A callbag listenable source that sends incremental numbers every x milliseconds

Callbag operator that broadcasts a single source to multiple sinks

Callbag operator that skips the first N data points of a source

Callbag operator that limits the total amount of data sent through

A standard for JS callbacks