Learn you advanced Akka Streams for great Good!

on YouTube ↗49m

" summary

Builds a working Akka Streams SSE client that reconnects on failure using the Last-Event-ID header, showing live code. Uses Akka HTTP unmarshalling to a Source[ServerSentEvent], combinators like mapConcat, throttle, zip and merge, and the GraphDSL to create a cyclic graph for retries. Implements a custom GraphStage that materializes a Future[Option[ServerSentEvent]] (the last element). Demonstration compiles and repeatedly reconnects to the server, proving the approach works.

AI-written summary · about

" chapters (29)

1. 0:00Intro
2. 1:18Akka Streams
3. 2:30Single String
4. 3:51Source Repeat
5. 6:12MapConcat
6. 7:45Iterator
7. 9:00materialized value
8. 11:29Recap
9. 12:38tuples
10. 13:23server sent events
11. 15:38linear flow
12. 18:04step by step
13. 22:20parallelism
14. 23:18source signal
15. 24:03restart
16. 24:36header
17. 26:45shape
18. 29:30graph stage logic
19. 30:25out handler
20. 31:30push
21. 32:34finish
22. 32:57fail
23. 33:25recovery
24. 35:28handler
25. 37:16tuple
26. 37:34source
27. 38:33unzip
28. 39:17implicits
29. 44:39docker logs

" related talks

• 42mLearn you Akka Streams for great Good!Heiko Seeberger · Scala Days Copenhagen 2017
• 46mAkka Streams & Reactive Streams in actionKonrad 'ktoso' Malawski · Scala Days Berlin 2016
• 01h 07mA Practical Introduction to Akka StreamsJacek Kunicki · JDD 2016
• 44mPatterns for Streaming Telemetry with Akka StreamsColin Breck · Scala Days Berlin 2018
• 01h 31mReactive Streams / Akka StreamsJohannes Rudolph, Mathias Doenitz · Scala World 2015
• 49mA Practical Introduction to Akka StreamsJacek Kunicki · Voxxed Days Vienna 2017
• 43mReactive Integration with Akka Streams and AlpakkaJacek Kunicki · GeeCON 2019
• 46mAkka Streams to the ExtremeHeiko Seeberger · Scala Days Lausanne 2019