After some more debugging, it appears that I'm getting a Cancel message before the entire file contents is downloaded. However, I'm not sure why that is. What would cause the stream to be cancelled in this example?
Thanks, Jason On Monday, June 15, 2015 at 9:11:38 AM UTC-7, Jason Martens wrote: > > Hello, > I'm continuing my attempts to write a robust chunked large file > downloader. I experience frequent timeouts when reading chunks (*cough* S3 > *cough*), so my original attempts just using stream elements were failing > due to a single chunk timing out. I now have an ActorPublisher that tracks > all the chunks to be downloaded (assumes the file size is known ahead of > time) and makes sure that each chunk is actually completed. However, after > downloading some number of chunks, the system stalls and I get a lot of > undeliverable message errors. I'm not sure why this is happening, and the > number of chunks completed before the system fails seems random so I'm > guessing I have a race condition somewhere. > > Here is what I currently have: > https://gist.github.com/ed6fd6f8aeabc5846aa2.git > > If anyone could give me some ideas what to look at, that would be very > helpful. > > Thanks! > Jason > -- >>>>>>>>>> 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.
