Akka Streams to the Extreme
summary
MOIA reproduces request handling as long‑running Akka Streams processes using source.queue, merge hub and flow with context to thread a remotable response handle (RespondD) through pipelines; a demo with buffer size 1 turns four rapid requests into two 200s and two 503s. Remote linking uses stream refs (sync ref) plus a kill switch and a restart-with-backoff to survive pod moves and cluster singleton failover; the multi‑node demo connects, fails over and reconnects successfully.
AI-written summary · about
chapters (44)
- 0:00Introduction
- 2:44Simplification of Akka
- 4:12The terminate method
- 5:04Server binding
- 7:05Pipeline
- 8:01Compositionality
- 9:26Advanced Features
- 10:03Simplified Demo
- 13:36Source Queue
- 14:54Promises
- 16:03Flow with Context
- 17:31Running Process
- 19:06Promise
- 21:34Testing
- 22:33Branching
- 22:56Merge Hub
- 25:33Move
- 25:51Word Shuffler
- 27:47Text Traveler
- 28:25Sink
- 29:10RespondDe
- 32:15Swiss Pondy
- 32:47Simple Solution
- 33:44Main Method
- 34:13Two Notes
- 34:26SyncRefs
- 35:09SyncRef
- 36:05KillSwitch
- 36:54Restart
- 37:12Demonstration
- 37:24SyncRef protocol
- 37:39SyncRef Uncomplete
- 38:44SyncRef Text
- 38:55Shuffler
- 39:45Restart Sync
- 40:02Back Off Sync
- 40:15API App
- 40:37Compile
- 40:48Timeout
- 41:37Second Node
- 42:30Backup Sync
- 43:02Stream II
- 43:27Thank you
- 43:42Questions
related talks
46mAkka Streams & Reactive Streams in action
48mStreaming all the things with Akka Streams
22mAdvanced Akka features
42mLearn you Akka Streams for great Good!
30mLEARN YOU AKKA STREAMS FOR GREAT GOOD!
49mLearn you advanced Akka Streams for great Good!
11mStreaming Libraries Shootout
43mReactive Integration with Akka Streams and Alpakka