LEARN YOU AKKA STREAMS FOR GREAT GOOD!
summary
Live coding shows Akka Streams (Reactive Streams implementation) using an ActorSystem and materializer to build runnable graphs: Source.single -> Sink.foreach prints a line, run returns a materialized Future[Done] when using keep.both/keep.right to capture sink completion. Demonstrates Source.maybe and Source.queue for external push, mapConcat to split lines into chars, throttle 42/sec and take(7) to print seven indented lines slowly, and a GraphDSL example that reconnects an SSE HTTP stream with a feedback loop — code runs and reconnects as expected.
AI-written summary · about
