Merge pull request #16 from clue-labs/close-on-data

Stop emitting events when closing stream during event handler

Author: clue

src/ControlCodeParser.php

@@ -84,6 +84,7 @@ public function close()
         }
 
         $this->closed = true;
+        $this->buffer = '';
 
         $this->input->close();
 

tests/ControlCodeParserTest.php

@@ -122,6 +122,18 @@ public function testEmitsDataInTwoChunkWithC0InBetweenWhileAddingDuringDataEvent
         $this->input->emit('data', array("hello\nworld"));
     }
 
+    public function testEmitsDataOnlyFirstChunkOfMultipleWhenClosingDuringFirstDataEvent()
+    {
+        // first data event is everything before control code
+        $first = $this->expectCallableOnceWith('hello');
+        $this->parser->on('data', $first);
+
+        // close the input stream on the first data event => no more data events
+        $this->parser->once('data', array($this->input, 'close'));
+
+        $this->input->emit('data', array("hello\nworld"));
+    }
+
     public function testEmitsC0AndData()
     {
         $this->parser->on('data', $this->expectCallableOnceWith("hello world"));