async http

Author: CodeWithSushil

.phpunit.cache/test-results

@@ -0,0 +1 @@
+{"version":1,"defects":{"AsyncHttpClientTest::test_simple_get_request":8},"times":{"AsyncHttpClientTest::test_simple_get_request":0.02}}

composer.json

@@ -7,7 +7,9 @@
         "ext-sockets": "*"
     },
     "require-dev": {
-        "phpunit/phpunit": "^12.2"
+        "phpunit/phpunit": "^12.2",
+        "phpstan/phpstan": "^2.1",
+        "laravel/pint": "^1.23"
     },
     "license": "MIT",
     "autoload": {
@@ -22,7 +24,7 @@
         }
     ],
     "scripts": {
-        "test": "vendor/bin/phpunit"
+        "test": "vendor/bin/phpstan"
     },
     "minimum-stability": "stable",
     "prefer-stable": true

phpstan.neon.dist

@@ -2,5 +2,4 @@ parameters:
   level: max
   paths:
     - src
-  autoload_directories:
-    - src
+

phpunit.xml

@@ -0,0 +1,25 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<phpunit xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:noNamespaceSchemaLocation="vendor/phpunit/phpunit/phpunit.xsd"
+         bootstrap="vendor/autoload.php"
+         cacheDirectory=".phpunit.cache"
+         executionOrder="depends,defects"
+         requireCoverageMetadata="true"
+         beStrictAboutCoverageMetadata="true"
+         beStrictAboutOutputDuringTests="true"
+         displayDetailsOnPhpunitDeprecations="true"
+         failOnPhpunitDeprecation="true"
+         failOnRisky="true"
+         failOnWarning="true" colors="true">
+    <testsuites>
+        <testsuite name="default">
+            <directory>tests</directory>
+        </testsuite>
+    </testsuites>
+
+    <source ignoreIndirectDeprecations="true" restrictNotices="true" restrictWarnings="true">
+        <include>
+            <directory>src</directory>
+        </include>
+    </source>
+</phpunit>

src/Http/MultiAsyncHandler.php

@@ -1,29 +1,34 @@
 <?php
+
 namespace Async\Http;
 
 class MultiAsyncHandler
 {
     private array $streams = [];
+
     private array $callbacks = [];
 
-    public function add(callable $generatorCallback, callable $onDone): void {
+    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];
+            $this->streams[(int) $socket] = $socket;
+            $this->callbacks[(int) $socket] = [$gen, $onDone];
         }
     }
 
-    public function run(): void {
+    public function run(): void
+    {
         while ($this->streams) {
             $read = array_values($this->streams);
-            $write = null; $except = null;
+            $write = null;
+            $except = null;
             stream_select($read, $write, $except, 5);
 
             foreach ($read as $socket) {
-                $id = (int)$socket;
+                $id = (int) $socket;
                 [$gen, $callback] = $this->callbacks[$id];
                 if ($gen->valid()) {
                     $response = $gen->current();
@@ -34,7 +39,8 @@ public function run(): void {
         }
     }
 
-    private function extractSocket(\Generator $gen): mixed {
+    private function extractSocket(\Generator $gen): mixed
+    {
         $r = new \ReflectionObject($gen);
         foreach ($r->getProperties() as $prop) {
             $prop->setAccessible(true);
@@ -43,6 +49,7 @@ private function extractSocket(\Generator $gen): mixed {
                 return $val;
             }
         }
+
         return null;
     }
 }

tests/AsyncHttpClientTest.php

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