Update Channeled.php

symplely · May 28, 2021 · a26fe5b · a26fe5b
1 parent 344f9c8
commit a26fe5b
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/Spawn/Channeled.php b/Spawn/Channeled.php
@@ -316,7 +316,7 @@ function () use ($future, $checkState) {
       } elseif (null !== $value) {
         // @codeCoverageIgnoreStart
         if (!\is_resource($this->futureOutput)) {
-          $this->futureOutput = \STDOUT;
+          $this->futureOutput = \fopen('php://stdout', 'w');
           \stream_set_write_buffer($this->futureOutput, 0);
         }
 
@@ -377,7 +377,7 @@ public function recv()
     }
 
     if (!\is_resource($this->futureInput)) {
-      $this->futureInput = \STDIN;
+      $this->futureInput = \fopen('php://stdin', 'r');
       \stream_set_read_buffer($this->futureInput, 0);
     }
 
@@ -417,7 +417,7 @@ public function kill(): void
   public function read(int $length = 0): string
   {
     if (!\is_resource($this->futureInput)) {
-      $this->futureInput = \STDIN;
+      $this->futureInput = \fopen('php://stdin', 'r');
       \stream_set_read_buffer($this->futureInput, 0);
     }
 
@@ -435,7 +435,7 @@ public function read(int $length = 0): string
   public function write($message): int
   {
     if (!\is_resource($this->futureInput)) {
-      $this->futureOutput = \STDOUT;
+      $this->futureOutput = \fopen('php://stdout', 'w');
       \stream_set_write_buffer($this->futureOutput, 0);
     }