Tallbag Packages

A factory of Shadow Callbags useful for implementing Tallbags

Extension of the Callbag spec to add operator metadata

Basic tallbag factories and operators to get started with

Tallbag operator that limits the total amount of data sent through

Tallbag factory that combines data from multiple tallbag sources

Tallbag factory that concatenates data from multiple tallbag sources

Tallbag operator that conditionally lets data pass through

Tallbag operator that flattens a higher-order tallbag source

Create a tallbag listenable source from events on a DOM node

Convert an iterable or iterator to a tallbag pullable source

Convert an observable to a tallbag listenable source

Convert a Promise to a tallbag listenable source

A tallbag listenable source that sends incremental numbers every x milliseconds

Tallbag operator that applies a transformation on data passing through it

Tallbag factory that merges data from multiple tallbag sources

Tallbag operator that combines consecutive values from the same source

Tallbag operator that broadcasts a single source to multiple sinks

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

Basically RxJS's fromFetch converted to a tallbag listenable source.