Sorry, I was mistaken, it was actually a server which broke the connection after responding to the first request of the batch. Multiple requests to httpbin.org were pipelined just fine. But if akka.http.host-connection-pool.max-connections is greater than one, the default behaviour is to open multiple TCP connections instead of pipelining. Why is that? How do I do pipelining first and open new TCP connections in parallel only when other connections' pipelines are saturated?
On Tuesday, August 18, 2015 at 3:44:05 PM UTC+3, [email protected] wrote: > > Hi, > > I'm trying to get akka-http client to pipeline HTTP requests in one TCP > connection. I rewrote what was based on Http().singleRequest into this: > > (path("batch-geocode") & put & entity(as[Map[String, String]])) { br => > val connectionPool = Http().cachedHostConnectionPool[String]("geocoder.ca") > val requests = br.mapValues(GeocodeRequest).toList.map(_.swap) > val ftrRs: Future[List[(String, StandardResponse)]] = Source(requests) > .via(connectionPool) > .mapAsync(4){ case (tryResponse, id) => > Future.fromTry(tryResponse) > .flatMap(transformResponse).recover{ > case t: Throwable => ErrorResponse(None, t.getMessage) > } > .map(id -> _) > }.runFold(List[(String, StandardResponse)]())((a,b) => b :: a) > > onSuccess(ftrRs){ case rs => > complete(OK -> rs.toMap) > } > } > > (In case you were wondering, I have a JSON codec that knows how to work > with scala Maps.) > > my config has > > akka.http.host-connection-pool { > max-connections = 2 > pipelining-limit = 4 > } > > > Wireshark consistently shows two TCP connections established one by one > (initiating SYN packets are adjacent in the log). However, if I set > max-connections to 1, akka-http actually sends two HTTP requests at once, > but after the first response is received, it immediately sends FIN, ACK to > the server and then opens another TCP connection and sends the second > request again to receive a response. Am I missing something? > -- >>>>>>>>>> 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.
