Streaming and event-based programming using FRP and RxJS
summary
Claim: treat events as collections using RxJS observables to write the same map/filter/merge code for array data, XHRs, mouse drags and WebSocket streams. Shows concrete operators: throttle, distinctUntilChanged, and mergeMap patterns that cancel previous requests to avoid out‑of‑order results. Describes schedulers and deterministic virtual‑time tests (Netflix uses Rx; codebase has ~1800 tests, 60–70 operators), and outlines work on backpressure/reactive‑streams and generator/async integration.
AI-written summary · about
chapters (36)
- 0:00Introduction
- 1:28No advanced functional programming techniques
- 1:49Reactive programming
- 3:42Node streams
- 4:11Streams as IO
- 5:41Reactive Extensions
- 6:29Netflix API
- 7:16Mouse Drag Event
- 8:29Callback Hell
- 9:14Cow Head
- 9:27Asynchronous programming
- 10:34Game programming
- 11:31Realtime data
- 12:32Finding ninjas
- 13:13Todo MVC
- 14:30Drag Drop
- 15:40Normal style collections
- 16:11Iterator pattern
- 16:27Observer pattern
- 18:28OnNextOnCompleted
- 19:12First class objects
- 20:31Query operators
- 21:07Rx is everywhere
- 22:03Marble diagrams
- 22:51Delay
- 23:32Synchronous
- 27:23Out of Order Search
- 28:31Netflix
- 29:06Hidden rows
- 29:53Parameterizing concurrency
- 31:18Testing FutureJS
- 32:28Backpressure
- 33:25Reactive Streams
- 33:54Observables as Levels
- 35:05Questions
- 35:24Highland Highline
related talks
27mReactive Programming in Node
41mAsynchronous JavaScript
42mConquering Time with Functional Reactive Programming
24mAdding Even More Fun to Functional Programming With RXJS
38mCuring your event processing blues with Rx
25mReinventing RxJS
25mRxJS all things!
21mReal-Time Stream Processing with Reactive-Extensions (RX)