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.
