Hi Gary, "completes with an error" in Reactive Streams sense. You might want to look at the specification https://github.com/reactive-streams/reactive-streams-jvm The error can originate in the Source (any of the Sources in more complex stream graphs), or in any of the transformation steps. The information about the error travels downstream until it reaches the Sink (or sinks). Sinks usually provide a Future as their materialized value, and in case of completed with a Failure. This is how error manifests itself to the "world" outside of the stream. If your application's design is such that the stream is owned by an Actor and the Actor needs to restart itself in case of Stream's failure you need to "connect the wires" yourself.
Cheers, Rafał W dniu niedziela, 6 marca 2016 21:48:59 UTC+1 użytkownik Gary Struthers napisał: > > Stream supervision is similar but different to Actor supervision. I don't > see what I'm supposed to do when a stream triggers a Supervision.Stop. What > does it mean that a stream "completes with an error"? Where is the error? > If I create a stream in an Actor is the Actor the stream's supervisor? Or > how is it different? > > Thanks, > Gary > -- >>>>>>>>>> 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 https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
