Akka Streams & Reactive Streams in action
summary
Akka Streams implements Reactive Streams with materialization and fusing to turn blueprints into a single optimized engine; demo shows Kafka -> stream -> WebSocket working end-to-end and a framed JSON/CSV upload feature as framed entity streaming (still unreleased). Actor integration uses a bounded queue or an actor-ref-with-ack pattern so downstream mailboxes stop growing — metrics from ~92 samples show mailbox size ≈1 under back-pressure. Also covers custom graph stages and persistence-query sources for event-sourced pipelines.
AI-written summary · about
chapters (8)
- 0:00Start
- 8:17Futures
- 11:04Direct Monitoring
- 12:16Materialization Phase
- 14:40Custom Stages
- 22:01Framed Entity Streaming
- 22:25Extract Data Bytes
- 40:43Message Types
related talks
01h 31mReactive Streams / Akka Streams
01h 01mThirst Quenching Streams for the Reactive Mind
34mRetrofit Your Java App with a Reactive Flow Pipeline
48mA Practical Introduction to Akka Streams
37mReactive Pipeline Talk
42mLearn you Akka Streams for great Good!
27mRetrofit your Java App with a Reactive Flow
01h 01mFrom Reactive Extensions to Reactive Streams