feat(shell): refactor Shell\execute to use async streams

Signed-off-by: azjezz <azjezz@protonmail.com>

CHANGELOG.md

@@ -16,3 +16,4 @@
 * refactored `Psl\IO` handles API.
 * introduced a new `Psl\File` component.
 * refactor `Psl\Filesystem\write_file`, `Psl\Filesystem\append_file`, and `Psl\Filesystem\read_file` to use `Psl\File` component.
+* refactor `Psl\Shell\execute` to use `Psl\IO\Stream` component.

docs/component/shell.md

@@ -14,6 +14,6 @@
 
 - [escape_argument](./../../src/Psl/Shell/escape_argument.php#L17)
 - [escape_command](./../../src/Psl/Shell/escape_command.php#L14)
-- [execute](./../../src/Psl/Shell/execute.php#L37)
+- [execute](./../../src/Psl/Shell/execute.php#L36)
 
 

src/Psl/Shell/execute.php

@@ -4,17 +4,16 @@
 
 namespace Psl\Shell;
 
+use Psl\Async;
 use Psl\Dict;
 use Psl\Env;
+use Psl\IO\Stream;
 use Psl\Str;
 use Psl\Vec;
-
-use function fclose;
 use function is_dir;
 use function is_resource;
 use function proc_close;
 use function proc_open;
-use function stream_get_contents;
 
 /**
  * Execute an external program.
@@ -71,11 +70,16 @@ function execute(
     }
     // @codeCoverageIgnoreEnd
 
-    $stdout_content = stream_get_contents($pipes[1]);
-    $stderr_content = stream_get_contents($pipes[2]);
+    $stdout = new Stream\StreamCloseReadHandle($pipes[1]);
+    $stderr = new Stream\StreamCloseReadHandle($pipes[2]);
+
+    [$stdout_content, $stderr_content] = Async\concurrently([
+        static fn(): string => $stdout->readAll(),
+        static fn(): string => $stderr->readAll(),
+    ])->await();
 
-    fclose($pipes[1]);
-    fclose($pipes[2]);
+    $stdout->close();
+    $stderr->close();
 
     $code = proc_close($process);
     if ($code !== 0) {