callbag sockets

A tiny but capable push & pull stream library for TypeScript and Flow

A standard for JS callbacks

Callbag operator that applies a transformation on data passing through it

Utility function for plugging callbags together in chain

Callbag factory that merges data from multiple callbag sources

Emits the values emitted by the source Callbag until a notifier Callbag emits a value

👜 Callbag source factory that emits values specified as arguments.

Callbag sink that consume both pullable and listenable sources

A callbag sink (listener) that connects an Observer a-la RxJS.

Callbag operator that conditionally lets data pass through

👜 Callbag which creates a source from a given factory when sink subscribes.

Creates a new Callbag given an optional producer

Callbag factory that concatenates data from multiple callbag sources

Callbag operator that broadcasts a single source to multiple sinks

OpenTelemetry instrumentation for `node:net` network API module

👜 Callbag source that never completes and emits no data.

👜 Callbag operator which converts source to a promise containing last emitted value.

Callbag factory that combines data from multiple callbag sources

👜 Callbag operator which resubscribes to the source given amount of times.