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 akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.