Use proper streaming interfaces for Readline input and output

Author: clue

src/Readline.php

@@ -33,14 +33,12 @@ class Readline extends EventEmitter
     private $history = null;
     private $encoding = 'utf-8';
 
+    private $input;
     private $output;
     private $sequencer;
 
     public function __construct(ReadableStreamInterface $input, WritableStreamInterface $output)
     {
-        // input data emits a single char into readline
-        $input->on('data', array($this, 'onChar'));
-
         $this->output = $output;
 
         $this->sequencer = new Sequencer();
@@ -89,6 +87,9 @@ public function __construct(ReadableStreamInterface $input, WritableStreamInterf
         $this->sequencer->addFallback(self::ESC_SEQUENCE, function ($bytes) {
             echo 'unknown sequence: ' . ord($bytes) . PHP_EOL;
         });
+
+        // input data emits a single char into readline
+        $input->on('data', array($this->sequencer, 'push'));
     }
 
     /**
@@ -374,7 +375,7 @@ public function redraw()
             // write output, then move back $reverse chars (by sending backspace)
             $output .= $buffer . str_repeat("\x08", $this->strwidth($buffer) - $this->getCursorCell());
         }
-        $this->write($output);
+        $this->output->write($output);
 
         return $this;
     }
@@ -394,18 +395,12 @@ public function redraw()
     public function clear()
     {
         if ($this->prompt !== '' || ($this->echo !== false && $this->linebuffer !== '')) {
-            $this->write("\r\033[K");
+            $this->output->write("\r\033[K");
         }
 
         return $this;
     }
 
-    /** @internal */
-    public function onChar($char)
-    {
-        $this->sequencer->push($char);
-    }
-
     /** @internal */
     public function onKeyBackspace()
     {
@@ -454,7 +449,7 @@ public function onKeyTab()
     public function onKeyEnter()
     {
         if ($this->echo !== false) {
-            $this->write("\n");
+            $this->output->write("\n");
         }
         $this->processLine();
     }
@@ -575,9 +570,4 @@ private function strwidth($str)
     {
         return mb_strwidth($str, $this->encoding);
     }
-
-    protected function write($data)
-    {
-        $this->output->write($data);
-    }
 }

tests/ReadlineTest.php

@@ -1,13 +1,19 @@
 <?php
 
 use Clue\React\Stdio\Readline;
+use React\Stream\ReadableStream;
 
 class ReadlineTest extends TestCase
 {
+    private $input;
+    private $output;
+    private $readline;
+
     public function setUp()
     {
-        $this->input = $this->getMock('React\Stream\ReadableStreamInterface');
-        $this->output = $this->getMockBuilder('Clue\React\Stdio\Stdout')->disableOriginalConstructor()->getMock();
+        $this->input = new ReadableStream();
+        $this->output = $this->getMock('React\Stream\WritableStreamInterface');
+
         $this->readline = new Readline($this->input, $this->output);
     }
 
@@ -480,7 +486,7 @@ public function testSetInputDuringEmitKeepsInput()
     private function pushInputBytes(Readline $readline, $bytes)
     {
         foreach (str_split($bytes, 1) as $byte) {
-            $readline->onChar($byte);
+            $this->input->emit('data', array($byte));
         }
     }
 }