A callbag operator that turns a pullable source into a listenable source.
pipe streams together and close all of them if one of them closes
A tiny but capable push & pull stream library for TypeScript and Flow
TypeScript definitions for pump
A standard for JS callbacks
Combine an array of streams into a single duplex stream using pump and duplexify
Clone a Readable stream, safely
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
👜 Callbag source factory that emits values specified as arguments.
A callbag sink (listener) that connects an Observer a-la RxJS.
Callbag factory that concatenates data from multiple callbag sources
A module that glues pump and bubble-stream-error to make things easier when your public API returns a stream.
Callbag sink that consume both pullable and listenable sources
Creates a new Callbag given an optional producer
Callbag operator that conditionally lets data pass through
Emits the values emitted by the source Callbag until a notifier Callbag emits a value
Callbag operator that broadcasts a single source to multiple sinks
👜 Callbag which creates a source from a given factory when sink subscribes.
👜 Callbag operator that emits items given it as arguments after it finishes emitting items emitted by source.
Convert an observable to a callbag listenable source
👜 Callbag operator which emits values emitted by the source as long as each value satisfies the given predicate, and then completes as soon as predicate is not satisfied.
TypeScript SDK for Pump Agent Payments