Real-Time Stream Processing with Reactive-Extensions (RX)
summary
Presents building a live Morse-code generator using RxJS to demonstrate real-time stream processing by wiring DOM events into timestamped observables, combining and buffering streams, and recovering from injected errors so the demo keeps running. Covers creating observables, using operators like switchMap and merge, managing subscriptions and subjects, writing a custom operator, and documenting behavior with marble diagrams; claims the patterns are reusable across languages.
AI-written summary · about
chapters (6)
- 0:00Introduction
- 3:14Combining streams
- 8:04Error handling
- 12:30Custom operators
- 16:43Error recovery
- 20:33Summary
related talks
32mReal-Time Stream Processing with Reactive-Extensions
37mStreaming and event-based programming using FRP and RxJS
27mReactive Programming in Node
37mFrom Zero to Hero with the Reactive Extensions for JavaScript
36mIntroduction to RxJS
25mRxJS all things!
42mReactive JavaScript with RxJS
25mReinventing RxJS