Support explicitly closing STDOUT

Author: clue

src/Stdio.php

@@ -26,7 +26,7 @@ public function __construct(LoopInterface $loop, ReadableStreamInterface $input
         }
 
         if ($output === null) {
-            $output = new Stdout(STDOUT);
+            $output = new Stdout();
         }
 
         if ($readline === null) {

src/Stdout.php

@@ -6,10 +6,21 @@
 
 class Stdout extends WritableStream
 {
+    public function __construct()
+    {
+        // STDOUT not defined ("php -a") or already closed (`fclose(STDOUT)`)
+        if (!defined('STDOUT') || !is_resource(STDOUT)) {
+            return $this->close();
+        }
+    }
+
     public function write($data)
     {
-        // TODO: use non-blocking output instead
+        if ($this->closed) {
+            return false;
+        }
 
+        // TODO: use non-blocking output instead
         fwrite(STDOUT, $data);
 
         return true;

tests/FunctionalExampleTest.php

@@ -55,6 +55,26 @@ public function testStubCanCloseStdinAndIsNotReadable()
         $this->assertContains('NO', $output);
     }
 
+    public function testStubCanCloseStdoutAndIsNotWritable()
+    {
+        $output = $this->execExample('php ../tests/stub/03-close-stdout.php 2>&1');
+
+        $this->assertEquals('', $output);
+    }
+
+    public function testPeriodicExampleViaInteractiveModeQuitsImmediately()
+    {
+        if (defined('HHVM_VERSION')) {
+            $this->markTestSkipped('Skipped interactive mode on HHVM');
+        }
+
+        $output = $this->execExample('echo "require(\"01-periodic.php\");" | php -a');
+
+        // starts with either "Interactive mode enabled" or "Interactive shell"
+        $this->assertStringStartsWith('Interactive ', $output);
+        $this->assertNotContains('you just said:', $output);
+    }
+
     private function execExample($command)
     {
         chdir(__DIR__ . '/../examples/');

tests/stub/03-close-stdout.php

@@ -0,0 +1,16 @@
+<?php
+
+use Clue\React\Stdio\Stdio;
+
+require __DIR__ . '/../../vendor/autoload.php';
+
+$loop = React\EventLoop\Factory::create();
+
+fclose(STDOUT);
+$stdio = new Stdio($loop);
+if ($stdio->isWritable()) {
+    throw new \RuntimeException('Not writable');
+}
+$stdio->close();
+
+$loop->run();