I'm building a library that is going to be used by 3rd-party. In one of my methods I return Stream[Item] that is asynchronously generated from result of paginated REST API call.
I'm using my modification of BulkPullerAsync <https://github.com/MfgLabs/akka-stream-extensions/blob/master/commons/src/main/scala/internals/source/BulkPullerAsync.scala>. My code is here <https://gist.github.com/cppexpert/a366bf3fbd34b53b2e4c>. I want recipient of my stream to be able to handle errors. According to documentation <http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0/scala/stream-error.html> I'm supposed to use custom Supervision.Decider. val decider: Supervision.Decider = { case ex => ex.printStackTrace() Supervision.Stop} implicit val mat = ActorMaterializer(ActorMaterializerSettings(system).withSupervisionStrategy(decider)) Unfortunately it doesn't catch exceptions thrown in my ActionPublisher. I see it handled, ActorPublisher.onError is called but it doesn't reach Supervision.Decider. It works with simple Stream provided in documentation. What should I do ? I expect that users of my Stream should not depend on nature of its implementation. Thanks! -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
