The Stdin is now internal to the Readline

Author: clue

src/Readline.php

@@ -3,6 +3,8 @@
 namespace Clue\React\Stdio;
 
 use Evenement\EventEmitter;
+use React\Stream\ReadableStreamInterface;
+use React\Stream\WritableStreamInterface;
 
 class Readline extends EventEmitter
 {
@@ -34,8 +36,11 @@ class Readline extends EventEmitter
     private $output;
     private $sequencer;
 
-    public function __construct($output)
+    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();

src/Stdio.php

@@ -22,18 +22,17 @@ public function __construct(LoopInterface $loop, $input = true)
 
         $this->output = new Stdout(STDOUT);
 
-        $this->readline = $readline = new Readline($this->output);
+        $this->readline = new Readline($this->input, $this->output);
 
         $that = $this;
 
-        // input data emits a single char into readline
-        $this->input->on('data', function ($data) use ($that, $readline) {
+        // stdin emits single chars
+        $this->input->on('data', function ($data) use ($that) {
             $that->emit('char', array($data, $that));
-            $readline->onChar($data);
         });
 
         // readline data emits a new line
-        $readline->on('data', function($line) use ($that) {
+        $this->readline->on('data', function($line) use ($that) {
             $that->emit('line', array($line, $that));
         });
 

tests/ReadlineTest.php

@@ -6,8 +6,9 @@ class ReadlineTest extends TestCase
 {
     public function setUp()
     {
+        $this->input = $this->getMock('React\Stream\ReadableStreamInterface');
         $this->output = $this->getMockBuilder('Clue\React\Stdio\Stdout')->disableOriginalConstructor()->getMock();
-        $this->readline = new Readline($this->output);
+        $this->readline = new Readline($this->input, $this->output);
     }
 
     public function testSettersReturnSelf()

tests/StdioTest.php

@@ -0,0 +1,19 @@
+<?php
+
+use React\EventLoop\Factory;
+use Clue\React\Stdio\Stdio;
+
+class StdioTest extends TestCase
+{
+    private $loop;
+
+    public function setUp()
+    {
+        $this->loop = Factory::create();
+    }
+
+    public function testCtor()
+    {
+        $stdio = new Stdio($this->loop);
+    }
+}