Emit error on unexpected end of LengtLimitedStream

Author: legionth

src/LengthLimitedStream.php

@@ -94,8 +94,7 @@ public function handleError(\Exception $e)
     public function handleEnd()
     {
         if (!$this->closed) {
-            $this->emit('end');
-            $this->close();
+            $this->handleError(new \Exception('Unexpected end event'));
         }
     }
 

tests/LengthLimitedStreamTest.php

@@ -105,4 +105,16 @@ public function testOutputStreamCanCloseInputStream()
 
         $this->assertFalse($input->isReadable());
     }
+
+    public function testHandleUnexpectedEnd()
+    {
+        $stream = new LengthLimitedStream($this->input, 5);
+
+        $stream->on('data', $this->expectCallableNever());
+        $stream->on('close', $this->expectCallableOnce());
+        $stream->on('end', $this->expectCallableNever());
+        $stream->on('error', $this->expectCallableOnce());
+
+        $this->input->emit('end');
+    }
 }