On Thursday, October 30, 2014 11:15:50 AM UTC+1, Akka Team wrote: > > Hi Adam, > > This might or might not be associated with the components of the stream >> itself; in my current scenario I have a sink which is a reactive tcp >> connection. >> > > What do you mean by a reactive tcp connection here? Is it an Akka TCP > stream? >
Established using akka.stream.io.StreamTcp. > I don't seem to be getting any errors (at least logged) by shutting down >> the other side of the tcp connection, however I do get "outside" errors, >> from the cluster/remoting watch - so I could use that to restart the whole >> thing, if only I could make some "supervisor hierarchy" for the stream. >> > > Streams have a built-in onComplete/cancel signal that is invoked when > things terminate. Akka TCP provides those signals when the TCP connection > goes away. I need to know more about the setup you have to see what is the > problem. > > There was a problem though related to Windows that "connection reset by > peer" events were lost, there is a bugfix/workaround pending for that, to > be released with 2.3.7. If you are running Windows there is a high > likeliness that you hit that bug. > I'm not running Windows (MacOS), but how could these signals be handled? I was looking for some handlers in the value returned by run() (e.g. onComplete, onError), but it seems not much is there :) Thanks, Adam -- >>>>>>>>>> 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.
