Succeed reads with null on closed stream

amphp · May 12, 2017 · f6e765c · f6e765c
1 parent c2eac67
commit f6e765c
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lib/ResourceInputStream.php b/lib/ResourceInputStream.php
@@ -6,6 +6,7 @@
 use Amp\Failure;
 use Amp\Loop;
 use Amp\Promise;
+use Amp\Success;
 
 class ResourceInputStream implements InputStream {
     const DEFAULT_CHUNK_SIZE = 8192;
@@ -87,7 +88,7 @@ public function read(): Promise {
         }
 
         if (!$this->readable) {
-            return new Failure(new ClosedException("The stream has been closed"));
+            return new Success; // Resolve with null on closed stream.
         }
 
         $this->deferred = new Deferred;