Continue parsing after a c0 code in the middle of a stream

Author: clue

src/ControlCodeParser.php

@@ -131,7 +131,7 @@ public function handleData($data)
                 $this->buffer = (string)substr($this->buffer, 1);
 
                 $this->emit('c0', array($data));
-                break;
+                continue;
             }
 
             // check following byte to determine type

tests/ControlCodeParserTest.php

@@ -87,6 +87,14 @@ public function testEmitsDataAndC0()
         $this->input->emit('data', array("hello world\n"));
     }
 
+    public function testEmitsC0AndData()
+    {
+        $this->parser->on('data', $this->expectCallableOnceWith("hello world"));
+        $this->parser->on('c0', $this->expectCallableOnceWith("\t"));
+
+        $this->input->emit('data', array("\thello world"));
+    }
+
     public function testEmitsCsiAndData()
     {
         $this->parser->on('data', $this->expectCallableOnceWith("hello"));

tests/FunctionalControlCodeParserTest.php

@@ -0,0 +1,31 @@
+<?php
+
+use React\EventLoop\Factory;
+use React\Stream\Stream;
+use Clue\React\Term\ControlCodeParser;
+
+class FunctionalControlCodeParserTest extends TestCase
+{
+    public function testPipingReadme()
+    {
+        $loop = Factory::create();
+
+        $input = new Stream(fopen(__DIR__ . '/../README.md', 'r'), $loop);
+        $parser = new ControlCodeParser($input);
+
+        $buffer = '';
+        $parser->on('data', function ($chunk) use (&$buffer) {
+            $buffer .= $chunk;
+        });
+
+        $loop->run();
+
+        $readme = str_replace(
+            "\n",
+            '',
+            file_get_contents(__DIR__ . '/../README.md')
+        );
+
+        $this->assertEquals($readme, $buffer);
+    }
+}