On Sunday, August 9, 2015 at 12:18:36 AM UTC-6, Tim Harper wrote: > > ... > One issue I'm having right away is respecting the materializer settings. > From a public standpoint, it would seem that all access to materialized / > fused operations are blocked, and I have no way to access the provided > SupervisorStrategy. This means that the custom PushPullStage I've > implemented for the map / filter / collect operations don't respect it. See > https://github.com/timcharper/acked-stream/blob/master/src/main/scala/acked/stream/AckedFlow.scala#L36 > . >
Specifically, to reproduce the first mentioned issue, run my test class, https://github.com/timcharper/acked-stream/blob/master/src/main/scala/m/Test.scala. It should finish the whole stream, but instead if fails after the first exception. Tim -- >>>>>>>>>> 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.
