How (Not) to Use Reactive Streams in Java 9+

on YouTube ↗42m

" summary

Java 9+ exposes java.util.concurrent.Flow as SPI interfaces, not ready-made stream implementations, and a naïve iterator-backed Publisher fails the Reactive Streams TCK tests (15 run, only one initially passes). Building a correct Publisher requires handling Subscription request semantics, atomic termination, avoiding synchronous unbounded recursion (stack overflow) and long-demand overflow; fixes pass many TCK cases but corner cases remain. Integration demo wires Reactor → Akka Streams processor → RxJava subscriber via the JDK interfaces and it works.

AI-written summary · about

" chapters (8)

1. 0:00Introduction
2. 3:20Reactive streams basics
3. 11:05Naive publisher implementation
4. 17:07Fixing publisher with TCK
5. 21:35Publisher pitfalls
6. 24:50JDK reactive streams as SPI
7. 35:23Cross-library integration demo
8. 39:17Key takeaways and resources

" related talks

• 01h 28mIntroduction to Reactive ProgrammingRossen Stoyanchev, Stephane Maldini · SpringOne2GX 2015
• 35mFlow and the Future of Reactive Systems on the JVMKonrad 'ktoso' Malawski · Oracle OpenWorld 2017
• 53mGetting into the Flow: building applications with Reactive StreamsTim van Eijndhoven · J-Fall 2018
• 47mReactive programming in JavaMario Fusco · Voxxed Days Ticino 2017
• 44mGet Ready for java.util.concurrent.flow!Piotr Wittchen · JDD 2017
• 01h 01mThirst Quenching Streams for the Reactive MindMary Grygleski · Global Summit for Java Devs 2020
• 44mThirst-Quenching Streams for the Reactive MindMary Grygleski · Build Stuff 2020
• 49mThirst Quenching Streams for the Reactive MindMary Grygleski · Devnexus 2020