Reactive programming in Java
summary
Covers Java’s reactive-streams support (Java 9 Flow API) and RxJava types (Flowable/Observable) implementing backpressure. Uses a temperature-sensor demo that emits one reading per second, fails ~1-in-10 and completes after three values; shows building a Subscription that requests N items, uses an Executor to change threads to avoid stack overflow, inserts a Processor to convert Fahrenheit to Celsius, and merges city streams — demonstrating the examples run and fail as designed.
AI-written summary · about
chapters (8)
- 0:00Reactive programming
- 3:38Four pillars of reactive apps
- 8:00Reactive programming as event streams
- 12:03Streams vs collections
- 14:37Flow API and Reactive Streams
- 23:56Flow API example
- 37:36RxJava introduction and operators
- 46:57Q&A
related talks
52mReactive Programming in Java
53mGetting into the Flow: building applications with Reactive Streams
49mReactive Programming in Java
56mThirst-quenching Streams for the Reactive Mind
24mBringing Reactive Programming to Java and Microservices
43mReactive Programming in Java
41mThe definite guide to reactive programming in Java
01h 28mIntroduction to Reactive Programming
