A callbag listenable source that sends incremental numbers every x milliseconds
Utility function for plugging callbags together in chain
Callbag factory that merges data from multiple callbag sources
A tiny but capable push & pull stream library for TypeScript and Flow
Callbag sink that consume both pullable and listenable sources
👜 Callbag which creates a source from a given factory when sink subscribes.
Callbag factory that combines data from multiple callbag sources
A callbag sink (listener) that connects an Observer a-la RxJS.
Callbag operator that broadcasts a single source to multiple sinks
👜 Callbag operator which converts source to a promise containing last emitted value.
Like callbag-interval, but can be paused and resumed upon pulling
👜 Callbag operator that buffers the stream until another stream emits a value.
👜 Callbag operator that maps to inner source, subscribe and emit in order.
👜 Callbag operator that emits only the last item emitted by the source.
Callbag operator that limits the total amount of data sent through
Callbag operator that flattens a higher-order callbag source
A implementation of the interval operator that emits immediately
Parse Postgres interval columns
A standard for JS callbacks
Callbag operator that skips the first N data points of a source
👜 Use callbag as React hook.
Callbag operator that applies a transformation on data passing through it
👜 Callbag source factory that emits values specified as arguments.
Creates a new Callbag given an optional producer