🌊
Push-based streams
Create an Observable from a handler that pushes values through next, error, and complete.
xObservableReactive streams for TypeScript
A small, dependency-free observable core with subjects and composable operators.
Skip to content
📡
Multicast subjects
A Subject is both an observable and an observer, sharing one emission sequence across all subscribers.
🧠
Stateful BehaviorSubject
Always holds a current value and replays it to every new subscriber on subscription.
🔗
Composable operators
Chain map, filter, distinctUntilChanged, and tap through a fully typed pipe.
🛡️
Safe by default
Handler and operator throws are routed to the observer's error handler instead of crashing the stream.
🪶
Zero dependencies
A tiny runtime with no external packages, shipped as both ESM and CommonJS.