Remove exception overwrite

Copy/paste oversight.
amphp · Apr 5, 2018 · 24b2530 · 24b2530
1 parent 1b75b12
commit 24b2530
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/lib/ResourceOutputStream.php b/lib/ResourceOutputStream.php
@@ -85,7 +85,7 @@ public function __construct($stream, int $chunkSize = null) {
                     // Broken pipes between processes on macOS/FreeBSD do not detect EOF properly.
                     if ($written === 0) {
                         if ($emptyWrites++ > self::MAX_CONSECUTIVE_EMPTY_WRITES) {
-                            $message = "Failed to write to stream";
+                            $message = "Failed to write to stream after multiple attempts";
                             if ($error = \error_get_last()) {
                                 $message .= \sprintf("; %s", $error["message"]);
                             }
@@ -110,7 +110,6 @@ public function __construct($stream, int $chunkSize = null) {
                 $resource = null;
                 $writable = false;
 
-                $exception = new StreamException("The stream was closed by the peer");
                 $deferred->fail($exception);
                 while (!$writes->isEmpty()) {
                     list(, , $deferred) = $writes->shift();