Learn you Akka Streams for great Good!
summary
Live coding builds a pipeline that prints seven indented lines character‑by‑character using Source.repeat.take(7), zip‑with‑index, mapConcat to chars, and throttle 42/sec; it uses Source/Flow/Sink stages, inspects the materialized value Future[Done] to terminate the ActorSystem, and explains autofusing and explicit async boundaries. The Graph DSL constructs an access‑log flow with broadcast/zip/merge topology, is packaged as the micro‑library accesses, and a separate SSE source demo reconnects every 3s starting from lastEventId 43 — all examples run successfully.
AI-written summary · about
chapters (10)
- 0:00Introduction to Akka Streams
- 1:06Basic graph building blocks
- 5:21Materialized values and lifecyle
- 8:36Advanced stream processing
- 13:43Optimization and code reuse
- 16:44Building custom graphs
- 21:18Graph API implementation details
- 31:16Server-sent events example
- 33:49Cyclic graph implementation
- 36:08Q&A and session wrap-up
related talks
01h 07mA Practical Introduction to Akka Streams
49mA Practical Introduction to Akka Streams
49mLearn you advanced Akka Streams for great Good!
46mAkka Streams & Reactive Streams in action
30mLive Coding: Building Stateful and Scalable Reactive Streams...
43mReactive Integration with Akka Streams and Alpakka
44mScalaz Stream: Rebirth
44mPatterns for Streaming Telemetry with Akka Streams