Introduction to Reactive Programming
summary
Defines a concrete interoperability contract (Reactive Streams) and shows real code: a naive publisher fails the Reactive Streams TCK, publisherFactory fixes recursion that crashes a naive run of 10,000 requests, and Reactor/RxJava provide composition with map/flatMap and backpressure. Demonstrates long.MAX_VALUE as unbounded demand, prefetch vs stop‑and‑wait strategies, hot vs cold sources, and that Java 9 adds a submissionPublisher in JDK9 bridge — useful if needing push‑style, nonblocking end‑to‑end pipelines.
AI-written summary · about
chapters (5)
- 0:00Introduction to speakers
- 1:55Motivation for reactive programming
- 27:44Reactive Streams specification
- 55:29Composition APIs overview
- 1:17:32Q&A and closing remarks
related talks
24mBringing Reactive Programming to Java and Microservices
01h 04mFrom Functional to Reactive Programming
49mReactive Programming in Java
41mThe definite guide to reactive programming in Java
44mThirst-Quenching Streams for the Reactive Mind
42mHow (Not) to Use Reactive Streams in Java 9+
49mThirst Quenching Streams for the Reactive Mind
56mThirst-quenching Streams for the Reactive Mind
