[akka-user] Re: [akka-http] Http().superPool() and MergeHub.source backpressure

2017-08-15 Thread Jeff
I'm embarrassed I forgot something so obvious. Much thanks! On Tuesday, August 15, 2017 at 8:50:27 AM UTC-7, johannes...@lightbend.com wrote: > > Hi Jeff, > > if you don't read the response bodies of all the responses, your pipeline > will stall because the super pool connection are still

[akka-user] Re: [akka-http] Http().superPool() and MergeHub.source backpressure

2017-08-15 Thread johannes . rudolph
Hi Jeff, if you don't read the response bodies of all the responses, your pipeline will stall because the super pool connection are still waiting for your code to actually read the responses. In your example, try to add `x.discardEntityBytes` (or actually read the entity) inside of the

[akka-user] Re: [akka-http] Http().superPool() and MergeHub.source backpressure

2017-08-14 Thread Jeff
Quickly following up on this. My understanding of how MergeHub works leads me to believe that all 100 requests in my example should fire, however only 8 of them do, and only 4 complete. On Wednesday, August 9, 2017 at 4:53:18 PM UTC-7, Jeff wrote: > > I am getting behavior that I do not