Hi,
There is nowhere in that shared snippet where you actually use the kill
switch to stop the stream?
A reasonable place to use the kill switch would be the postStop hook of the
actor.
This 3 part series of articles by Colin Breck may help:
http://blog.colinbreck.com/integrating-akka-streams-and-
I cannot stop an actor running akka stream even with killswitch. How do I
properly stop an actor running an akka stream?
private def startStream(maybeOffset: Option[ProcessedEventOffset]): Unit = {
implicit val materializer = ActorMaterializer()
val publisher = SomePublisher
val (killSwi
