Re: [akka-user] Cannot stop actor running akka stream

2017-07-18 Thread Akka Team
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-

[akka-user] Cannot stop actor running akka stream

2017-07-06 Thread Lap Ming Lee
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