Fix incomplete StreamInterface implementation in PsrMessageStream

Author: luzrain

src/Internal/PsrMessageStream.php

@@ -16,6 +16,8 @@ final class PsrMessageStream implements StreamInterface
 
     private bool $isEof = false;
 
+    private bool $isClosed = false;
+
     private int $position = 0;
 
     public function __construct(private readonly ReadableStream $source, private readonly ?int $size = null)
@@ -32,6 +34,7 @@ public function close(): void
         $this->source->close();
         $this->buffer = '';
         $this->isEof = true;
+        $this->isClosed = true;
     }
 
     public function detach(): void
@@ -46,6 +49,10 @@ public function eof(): bool
 
     public function getContents(): string
     {
+        if ($this->isClosed) {
+            throw new \RuntimeException("Stream is closed");
+        }
+
         $buffer = $this->buffer;
         $this->buffer = '';
 
@@ -69,7 +76,7 @@ public function getSize(): ?int
 
     public function isReadable(): bool
     {
-        return !$this->eof();
+        return !$this->isClosed;
     }
 
     public function isSeekable(): bool
@@ -84,7 +91,7 @@ public function isWritable(): bool
 
     public function read(int $length): string
     {
-        if ($this->eof()) {
+        if ($this->isClosed) {
             throw new \RuntimeException("Stream is closed");
         }
 

test/Internal/PsrMessageStreamTest.php

@@ -93,8 +93,7 @@ public function testTell(): void
         self::assertSame('', $requestStream->read(8192));
         self::assertSame(6, $requestStream->tell());
         self::assertTrue($requestStream->eof());
-        self::assertFalse($requestStream->isReadable());
-
+        self::assertTrue($requestStream->isReadable());
     }
 
     public function testRewindThrowsException(): void

test/PsrAdapterTest.php

@@ -267,7 +267,7 @@ public function testToPsrResponseReturnsResponseWithStreamableBody(): void
 
         self::assertSame('content', $body->read(8192));
         self::assertTrue($body->eof());
-        self::assertFalse($body->isReadable());
+        self::assertTrue($body->isReadable());
     }
 
     public function testFromPsrResponseWithRequestReturnsResultWithSameRequest(): void