Catch errors to prevent hanging error connections (#10)

antonkomarev · web-flow · commit 8d2627d0bf0f · 2020-06-02T08:15:11.000+09:00
diff --git a/src/Internal/Sink.php b/src/Internal/Sink.php
@@ -27,6 +27,12 @@ public function __construct(ConnectionInterface $src)
                 $this->dst->end();
             }
         });
+        $src->on('error', function () {
+            $this->end = true;
+            if ($this->dst) {
+                $this->dst->end();
+            }
+        });
     }
 
     public function pipe(WritableStreamInterface $dst)

Original file line number	Diff line number	Diff line change
`@@ -27,6 +27,12 @@ public function __construct(ConnectionInterface $src)`
`27`	`27`	`$this->dst->end();`
`28`	`28`	`}`
`29`	`29`	`});`
	`30`	`+ $src->on('error', function () {`
	`31`	`+ $this->end = true;`
	`32`	`+ if ($this->dst) {`
	`33`	`+ $this->dst->end();`
	`34`	`+ }`
	`35`	`+ });`
`30`	`36`	`}`
`31`	`37`
`32`	`38`	`public function pipe(WritableStreamInterface $dst)`