Thanks.
I actually found the bug that was causing my stream to get stuck. I was
running a Source.queue in an actor, and calling context.become (without
stashing) immediately afterwards.
I found that one of the stream elements was reaching the initial receive
handler, and thus not getting acked.
AbruptTerminationException happens when the actor running the stream (the
"graph interpreter") is terminated without the stream first completing or
failing, for example if terminating an actor system with a running stream
in it.
The paths of the supervisors are pretty much an implementation
I'm trying to write two ScalaTest tests to compare two approaches to
driving a Flow that sends out emails. In one approach the flow is sourced
using eventsByTag from akka-persistence-query. In the other, I uses
SourceQueue.offer after receiving a message via AtLeastOnceDelivery. The
test ends with
