I noticed this today:
implicit val ec = ExecutionContext.global
case object LeException extends Exception("le fail")
implicit val materializer =
ActorMaterializer(ActorMaterializerSettings(actorSystem).withSupervisionStrategy(Supervision.resumingDecider
: Supervision.Decider))
val result = scala.concurrent.Await.result({
Source(Range(1,20)).log("hi", { n => throw LeException
}).runWith(Sink.fold(0)(_ + _))
}, 1 second)
result should be (0)
I'd expect the stream to resume, but instead, the stream is falling. I can see
why this behavior would make sense, since the log is not really manipulating
the stream. I'm wondering if that should be highlighted in the docs, just to
warn people. I can send a doc pull request if so.
Thanks,
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.
