Fix applying SizeLimitingReadableStream if limit is 0

amphp · May 9, 2024 · 04d176c · 04d176c
1 parent a271b62
commit 04d176c
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/Interceptor/DecompressResponse.php b/src/Interceptor/DecompressResponse.php
@@ -53,10 +53,14 @@ private function addAcceptEncodingHeader(Request $request): void
  private function decompressResponse(Response $response): Response
  {
  if (($encoding = $this->determineCompressionEncoding($response))) {
+ $stream = new DecompressingReadableStream($response->getBody(), $encoding);
+
  $sizeLimit = $response->getRequest()->getBodySizeLimit();
- $decompressedBody = new DecompressingReadableStream($response->getBody(), $encoding);
+ if ($sizeLimit > 0) {
+ $stream = new SizeLimitingReadableStream($stream, $sizeLimit);
+ }
 
- $response->setBody(new SizeLimitingReadableStream($decompressedBody, $sizeLimit));
+ $response->setBody($stream);
  $response->removeHeader('content-encoding');
  }