Sounds like a good improvement, please open a ticket (or submit a PR if you would like to, thanks in advance).
-- Konrad `ktoso` Malawski Akka <http://akka.io> @ Lightbend <http://lightbend.com> On 1 March 2017 at 11:03:32, Stephen Couchman ([email protected]) wrote: Well, I was able to resolve my problem but only by going to the application.conf file and setting it universally via akka.http.host-connection-pool.client.idle-timeout. I suspect there was another way, but the documentation on the many many variations of idle-timeout make it difficult to figure out what needed to be changed. The exception should probably be changed to specify which setting it came from as a full path. On Friday, February 24, 2017 at 12:32:52 PM UTC-5, Stephen Couchman wrote: > > Hi, > > > I'm attempting to process a SSE stream through Akka-Http client with the > help of alpakka-sse. > > Alpakka offloads the connection creation to a user supplied function. I'm > using the following (as a test): > > val connectionSettings = ConnectionPoolSettings(system).withIdleTimeout( > 10.seconds) > private def sendRequest(req: HttpRequest) = { > Http().singleRequest(request = req, settings = connectionSettings) > } > > > I've also tried several other values of withIdleTimeout including > Duration.Inf, which was my original intention. The server only sends > events when it has something to report so they can be few and far between. > > > No matter what I set the idle timeout to though, I always end up with: > > "akka.stream.scaladsl.TcpIdleTimeoutException: TCP idle-timeout > encountered on connection to [192.168.0.2:9000], no bytes passed in the > last 1 minute" *(specifically 1 minute, never any other value)* > > > I tried hooking the debugger up to akka.stream.impl.io.TcpIdleTimeout.apply > and at the only time that's being invoked it seems to be getting the > default settings object instead of the one I provided. Tracing further has > proven difficult thanks to the thread context switches inherent in the > Stream/Actor process. > > Is the settings parameter only sometimes-effective? > > Any advice is appreciated. > > Thanks! > -- >>>>>>>>>> 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. -- >>>>>>>>>> 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.
