Add support to process file async

Author: terremoth

demos/demo.php

@@ -3,17 +3,34 @@
 require_once 'vendor/autoload.php';
 
 use Terremoth\Async\Process;
-
+use Terremoth\Async\File;
 
 $process = new Process();
-echo time() . ' :: Sending process. You should not wait any longer to see next message: ' . PHP_EOL;
-$process->send(function () {
+echo date('c') . ' :: Sending process. You should not wait any longer to see next message: ' . PHP_EOL;
+try {
+    $process->send(function () {
+
+        $var1 = 4;
+        $var2 = 2 + 2;
+
+        sleep(5);
+
+        if ($var1 == $var2) {
+            echo 2;
+            file_put_contents('demo.txt', 'Hello, World! At: ' . date('c'));
+        }
+    });
+} catch (Exception $e) {
+    echo $e->getMessage();
+}
 
-    sleep(5);
-    if (1 == 1) {
-        echo 2;
-        file_put_contents('demo.txt', 'Hello, World!');
-    }
-});
+echo date('c') . ' :: This is the next message' . PHP_EOL;
+echo date('c') . ' :: Now let\'s process a file that takes a long time...' . PHP_EOL;
 
-echo time() . ' :: This is the next message' . PHP_EOL;
+try {
+    $file = new File(__DIR__ . DIRECTORY_SEPARATOR . 'time-wasting-file.php');
+    $file->run();
+    echo date('c') . ' :: Ended...' . PHP_EOL;
+} catch (Exception $e) {
+    echo $e->getMessage();
+}

demos/time-wasting-file.php

@@ -0,0 +1,8 @@
+<?php
+
+for ($i = 1; $i <= 5; $i++) {
+    echo $i . '...' . PHP_EOL;
+    sleep(1);
+}
+
+file_put_contents('demo-file.txt', 'Hello users! At: ' . date('c'));

src/Terremoth/Async/File.php

@@ -0,0 +1,31 @@
+<?php
+
+namespace Terremoth\Async;
+
+use Exception;
+use Symfony\Component\Process\Process as SymfonyProcess;
+
+class File
+{
+    /**
+     * @throws Exception
+     */
+    public function __construct(private readonly string $file, private readonly array $args = [])
+    {
+        if (!is_readable($this->file)) {
+            throw new Exception('File ' . $this->file . ' does not exists or is not readable!');
+        }
+    }
+
+    public function run(): int
+    {
+        $template = [PHP_BINARY, $this->file, ...$this->args, '&'];
+
+        if (PHP_OS_FAMILY === 'Windows') {
+            $template = ['start', '""', '/B', PHP_BINARY, $this->file, ...$this->args];
+        }
+
+        $process = new SymfonyProcess($template);
+        return $process->run();
+    }
+}