Thanks Rafał, So I have a Future callback. If this in in an Actor I doubt it is safe for the Actor to retry the stream. The safe thing is just to throw an exception if the Future fails.
Gary On Sunday, March 6, 2016 at 2:21:37 PM UTC-8, Rafał Krzewski wrote: > > 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.
