Make BufferedReader implement ReadableStream

src/BufferedReader.php

@@ -6,8 +6,9 @@ use Amp\Cancellation;
 use Amp\ForbidCloning;
 use Amp\ForbidSerialization;
 
-final class BufferedReader
+final class BufferedReader implements ReadableStream, \IteratorAggregate
 {
+    use ReadableStreamIteratorAggregate;
     use ForbidCloning;
     use ForbidSerialization;
 
@@ -20,6 +21,35 @@ final class BufferedReader
     ) {
     }
 
+    /**
+     * Closes the resource, marking it as unusable.
+     * Whether pending operations are aborted or not is implementation dependent.
+     */
+    public function close(): void
+    {
+        $this->stream->close();
+    }
+
+    /**
+     * Returns whether this resource has been closed.
+     *
+     * @return bool {@code true} if closed, otherwise {@code false}
+     */
+    public function isClosed(): bool
+    {
+        return $this->stream->isClosed();
+    }
+
+    /**
+     * Registers a callback that is invoked when this resource is closed.
+     *
+     * @param \Closure():void $onClose
+     */
+    public function onClose(\Closure $onClose): void
+    {
+        $this->stream->onClose($onClose);
+    }
+
     /**
      * @template TString as string|null
      *