async http

Author: CodeWithSushil

.editorconfig

@@ -0,0 +1,6 @@
+parameters:
+  level: max
+  paths:
+    - src
+  autoload_directories:
+    - src

.gitattributes

@@ -0,0 +1,48 @@
+<?php
+namespace AsyncHttp\Http;
+
+class MultiAsyncHandler
+{
+    private array $streams = [];
+    private array $callbacks = [];
+
+    public function add(callable $generatorCallback, callable $onDone): void {
+        $gen = $generatorCallback();
+        $gen->rewind();
+        $socket = $this->extractSocket($gen);
+        if ($socket) {
+            $this->streams[(int)$socket] = $socket;
+            $this->callbacks[(int)$socket] = [$gen, $onDone];
+        }
+    }
+
+    public function run(): void {
+        while ($this->streams) {
+            $read = array_values($this->streams);
+            $write = null; $except = null;
+            stream_select($read, $write, $except, 5);
+
+            foreach ($read as $socket) {
+                $id = (int)$socket;
+                [$gen, $callback] = $this->callbacks[$id];
+                if ($gen->valid()) {
+                    $response = $gen->current();
+                    $callback($response);
+                    unset($this->streams[$id], $this->callbacks[$id]);
+                }
+            }
+        }
+    }
+
+    private function extractSocket(\Generator $gen): mixed {
+        $r = new \ReflectionObject($gen);
+        foreach ($r->getProperties() as $prop) {
+            $prop->setAccessible(true);
+            $val = $prop->getValue($gen);
+            if (is_resource($val) && get_resource_type($val) === 'stream') {
+                return $val;
+            }
+        }
+        return null;
+    }
+}

phpstan.neon.dist

@@ -0,0 +1,14 @@
+<?php
+use PHPUnit\Framework\TestCase;
+use AsyncHttp\Http\AsyncHttpClient;
+
+class AsyncHttpClientTest extends TestCase
+{
+    public function testSimpleGetRequest()
+    {
+        $client = new AsyncHttpClient();
+        foreach ($client->get('https://jsonplaceholder.typicode.com/posts/1') as $response) {
+            $this->assertStringContainsString('userId', $response->getBody());
+        }
+    }
+}