AsyncHandler propagate netty channel for backpressure

[Zeymo]

Maybe inject netty channel in on onBodyPartReceived for slow client consumer in order to do channel.setAutoRead() operation ?

[slandelle]

Have you tried the reactive streams module?

[Zeymo]

reactive streams module just buffer body in queue，it not avoid OOM when client consumer slow. It's better to invoke netty origin channel.config().setAutoread(false) backpressure TCP RCV_BUF than buffer in the queue

[n-miles]

I also am interested in having a backpressure mechanism

[n-miles]

@Zeymo On using the reactive streams stuff that already exists in the library, it looks like AHC is properly handling backpressure. I am able to very slowly stream thousands of multi-gigabyte files concurrently with minimal heap usage and no issues. It sounds like you've got an issue with the rest of your code not propagating backpressure properly.

@slandelle I recommend closing this issue.

[slandelle]

@namiles Thanks for your feedback! closing