run http requests asynchronously

Innmind · Nov 5, 2023 · ac41d76 · ac41d76
1 parent 7e2975d
commit ac41d76
Show file tree

Hide file tree

Showing 3 changed files with 63 additions and 3 deletions.
diff --git a/composer.json b/composer.json
@@ -17,7 +17,7 @@
     "require": {
         "php": "~8.2",
         "innmind/immutable": "~5.2",
-        "innmind/operating-system": "~4.0",
+        "innmind/operating-system": "~4.1",
         "innmind/filesystem": "~7.3"
     },
     "autoload": {

diff --git a/proofs/functional.php b/proofs/functional.php
@@ -9,7 +9,15 @@
 use Innmind\OperatingSystem\Factory;
 use Innmind\TimeContinuum\Earth\Period\Second;
 use Innmind\Filesystem\Name;
-use Innmind\Url\Path;
+use Innmind\Http\{
+    Request,
+    Method,
+    ProtocolVersion,
+};
+use Innmind\Url\{
+    Url,
+    Path,
+};
 use Innmind\Immutable\Sequence;
 use Innmind\BlackBox\Set;
 
@@ -229,4 +237,46 @@ static function($os) use ($assert, &$chunks) {
             );
         },
     );
+
+    yield test(
+        'HTTP requests are handled asynchronously',
+        static function($assert) {
+            $order = [];
+            Forerunner::of(Factory::build())(null, Predetermined::of(
+                static function($os) use ($assert, &$order) {
+                    $os
+                        ->remote()
+                        ->http()(Request::of(
+                            Url::of('https://httpbin.org/delay/2'),
+                            Method::get,
+                            ProtocolVersion::v11,
+                        ))
+                        ->match(
+                            static fn() => null,
+                            static fn() => null,
+                        );
+                    $order[] = 'first';
+                },
+                static function($os) use ($assert, &$order) {
+                    $os
+                        ->remote()
+                        ->http()(Request::of(
+                            Url::of('https://httpbin.org/delay/1'),
+                            Method::get,
+                            ProtocolVersion::v11,
+                        ))
+                        ->match(
+                            static fn() => null,
+                            static fn() => null,
+                        );
+                    $order[] = 'second';
+                },
+            ));
+
+            $assert->same(
+                ['second', 'first'],
+                $order,
+            );
+        },
+    );
 };
diff --git a/src/Task.php b/src/Task.php
@@ -7,6 +7,10 @@
     Factory,
     OperatingSystem,
 };
+use Innmind\TimeContinuum\Earth\{
+    ElapsedPeriod,
+    Period\Millisecond,
+};
 
 /**
  * @template R
@@ -46,7 +50,13 @@ public function start(OperatingSystem $synchronous): mixed
                         $suspend,
                         $config->streamCapabilities(),
                     ))
-                    ->haltProcessVia(Asynchronous\Halt::of($suspend)),
+                    ->haltProcessVia(Asynchronous\Halt::of($suspend))
+                    ->withHttpHeartbeat(
+                        ElapsedPeriod::of(10), // this is blocking the active task so it needs to be low
+                        static fn() => $suspend(Suspend\Halt::of( // this allows to jump between tasks
+                            Millisecond::of(1),
+                        )),
+                    ),
             ),
         ));