Dear List,
I've a little app that uses (the awesome) akka-streams over TCP.
The client sends a request by doing
def askServer() =
Source(query)
.via(Tcp().outgoingConnection(serverAddress))
.runForeach(processOneChunk)
.onComplete(completionHandler)
and the server gets connection, process the query that way
val handler = Sink.foreach[Tcp.IncomingConnection] { connection =>
val flow = someFlow
connection.handleWith(flow)
}
val connections = Tcp().bind(hostName, port)
val binding = connections.to(handler).run()
It works 99% of the time, but under heavy load sometimes two calls to
askServer get pipelined into the same TcpIncomingConnection, meaning that a
given "someFlow" now has two inbound "queries".
Is it expected? The second query fails every time because the tcp
connection is closed too early.
Many thanks in advance for your help, and keep up the good work!!
William
Mobile : (+1) (415) 683-1484
Web : http://williamleferrand.github.com/
<http://www.linkedin.com/in/williamleferrand>
--
>>>>>>>>>> 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.
