Reactive Programming with RxPy
summary
Shows concrete use of RxPy with a Tornado websocket calling the GitHub API, implementing observables, observers and subjects and observables to multicasts streams. Demonstrates operators: filter, flat_map, combine_latest, throttle/interval and do_action, and uses on_error/on_complete for centralized error handling. Builds a working example that polls and filters incoming data and joins user input with periodic fetches; works in-process with threads but not distributed across machines.
AI-written summary · about
chapters (7)
- 0:00Start
- 1:42What Does Reactive Programming Really Means?
- 3:16Why Reactive Programming?
- 5:49Observable and Observer
- 8:30Data Operators in Reactive Programming
- 14:00Advantages of Reactive Programming
- 14:37Trying it out
related talks
34mReactive Programming: Navigating Asynchrony with RxPy
49mReactive Programming in Java
45mPHP Reactive Programming
21mReal-Time Stream Processing with Reactive-Extensions (RX)
37mStreaming and event-based programming using FRP and RxJS
27mReactive Programming in Node
52mReactive Programming in Java
36mSwift & ReactiveX – Asynchronous Event-Based Funsies with RxSwift
