Explicitly end input stream on CTRL+D

Author: clue

examples/01-periodic.php

@@ -16,10 +16,16 @@
 });
 
 // react to commands the user entered
-$stdio->on('line', function ($line) use ($stdio, $timer) {
+$stdio->on('line', function ($line) use ($stdio, $loop, $timer) {
     $stdio->writeln('you just said: ' . $line . ' (' . strlen($line) . ')');
 
-    $timer->cancel();
+    $loop->cancelTimer($timer);
+    $stdio->end();
+});
+
+// cancel periodic timer if STDIN closed
+$stdio->on('end', function () use ($stdio, $loop, $timer) {
+    $loop->cancelTimer($timer);
     $stdio->end();
 });
 

src/Readline.php

@@ -47,6 +47,7 @@ public function __construct(ReadableStreamInterface $input, WritableStreamInterf
             "\n" => 'onKeyEnter',
             "\x7f" => 'onKeyBackspace',
             "\t" => 'onKeyTab',
+            "\x04" => 'closeInput', // CTRL+D
 
             "\033[A" => 'onKeyUp',
             "\033[B" => 'onKeyDown',
@@ -838,6 +839,14 @@ public function pipe(WritableStreamInterface $dest, array $options = array())
         return $dest;
     }
 
+    public function closeInput()
+    {
+        if ($this->linebuffer !== '') {
+            $this->processLine();
+        }
+        $this->handleEnd();
+    }
+
     public function close()
     {
         if ($this->closed) {

src/Stdio.php

@@ -241,7 +241,7 @@ public function handleError(\Exception $e)
     /** @internal */
     public function handleEnd()
     {
-        $this->emit('end', array());
+        $this->emit('end');
     }
 
     /** @internal */

tests/ReadlineTest.php

@@ -223,6 +223,24 @@ public function testDataEventWillBeEmittedForEmptyLine()
         $this->input->emit('data', array("\n"));
     }
 
+    public function testEndInputWithoutDataOnCtrlD()
+    {
+        $this->readline->on('data', $this->expectCallableNever());
+        $this->readline->on('end', $this->expectCallableOnce());
+        $this->readline->on('close', $this->expectCallableOnce());
+
+        $this->input->emit('data', array("\x04"));
+    }
+
+    public function testEndInputWithIncompleteLineOnCtrlD()
+    {
+        $this->readline->on('data', $this->expectCallableOnceWith('hello'));
+        $this->readline->on('end', $this->expectCallableOnce());
+        $this->readline->on('close', $this->expectCallableOnce());
+
+        $this->input->emit('data', array("hello\x04"));
+    }
+
     public function testWriteSimpleCharWritesOnce()
     {
         $this->output->expects($this->once())->method('write')->with($this->equalTo("\r\033[K" . "k"));