An alternative way to address the issue can be buffer release as part of Compressor.ByteBufInputStream.close() method. For example, SocketInputStream works this way and closes the underlying socket as part of close call. But I think it's better to be explicit and close it within the same section that used it.

Hi @kulabun,

Thank you for the PR. I looked through the class InternalStreamConnection trying to see whether there are other places where we may not release buffers, and pushed a new commit.

Using your code from JAVA-4510 I confirmed that after the changes threads are not blocked due to ConcurrentPool.maxSize being exhausted. This can be done quickly by changing the ConcurrentPool.INFINITE_SIZE constant from Integer.MAX_VALUE to something small.