A set of commonly used stream operators implemented as callbags with Typescript and ES modules

callbags sandbox

rtl-sdr ads-b decoding and display

A collection of learning resources for topics related to reactive programming

An application created for a project

Callbag-refactored RSI-ASR-App

callbags + JSX: fast and tiny interactive web apps

👜 Callbag operator that remembers last event, so that a newly added listener will immediately receive that memorised event.

👜 Use callbag as React hook.

👜 Callbag source factory that emits values specified as arguments.

👜 Callbag implementation in C#

👜 Callbag operator that maps to inner source, subscribe and emit in order.

🧰 fast reactive/iterable programming framework

👜 Callbag operator that emits only the last item emitted by the source.

👜 Callbag operator that pulls from source when provided listenable emits.

👜 Callbag listenable source which emits value describing time progress (number between 0 an 1) since the subscription (using requestAnimationFrame) - useful for animations.

👜 Callbag listenable source which emits milliseconds elapsed since the subscription (using requestAnimationFrame) - useful for animations.

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

👜 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.

👜 Callbag operator that emits items given it as arguments after it finishes emitting items emitted by source.