Create base

phanxipang · Jul 3, 2023 · 3535366 · 3535366
1 parent e0e80b9
commit 3535366
Show file tree

Hide file tree

Showing 14 changed files with 82 additions and 407 deletions.
diff --git a/composer.json b/composer.json
@@ -20,18 +20,14 @@
         }
     ],
     "require": {
-        "php": "^8.1"
+        "php": "^8.1",
+        "jenky/atlas": "^0.4"
     },
     "require-dev": {
         "friendsofphp/php-cs-fixer": "^3.15",
         "guzzlehttp/guzzle": "^7.5",
-        "jenky/atlas": "1.x-dev",
-        "jenky/atlas-mock-client": "^1.0",
         "phpstan/phpstan": "^1.10",
-        "phpunit/phpunit": "^9.0",
-        "react/async": "^4.1",
-        "react/http": "^1.9",
-        "symfony/var-dumper": "^6.3"
+        "phpunit/phpunit": "^9.0"
     },
     "autoload": {
         "psr-4": {
@@ -62,10 +58,6 @@
             "@test"
         ]
     },
-    "suggest": {
-        "react/http": "Required to send concurrent requests using React pool",
-        "react/async": "Required to send concurrent requests using React pool"
-    },
     "extra": {
         "branch-alias": {
             "dev-main": "1.x-dev"

diff --git a/src/Guzzle/Pool.php b/src/Guzzle/Pool.php
diff --git a/src/Guzzle/ResolvePromise.php b/src/Guzzle/ResolvePromise.php
diff --git a/src/PoolFactory.php b/src/PoolFactory.php
diff --git a/src/PoolInterface.php b/src/PoolInterface.php
@@ -4,17 +4,22 @@
 
 namespace Jenky\Atlas\Pool;
 
-use Jenky\Atlas\Response;
-
+/**
+ * @template TReq
+ * @template TRes
+ */
 interface PoolInterface
 {
+    /**
+     * Set the maximum number of requests to send concurrently.
+     */
     public function concurrent(int $concurrency): PoolInterface;
 
     /**
      * Send concurrent requests.
      *
-     * @param  iterable $requests
-     * @return array<array-key, Response>
+     * @param  iterable<TReq> $requests
+     * @return array<array-key, TRes>
      */
     public function send(iterable $requests): array;
 }
diff --git a/src/React/Client.php b/src/React/Client.php
diff --git a/src/React/Pool.php b/src/React/Pool.php
diff --git a/tests/AkamaiTileRequest.php b/tests/AkamaiTileRequest.php
diff --git a/tests/DummyRequest.php b/tests/DummyRequest.php
@@ -0,0 +1,26 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Jenky\Atlas\Pool\Tests;
+
+use Jenky\Atlas\Request;
+
+final class DummyRequest extends Request
+{
+    public function __construct(
+        private string $uri = 'https://example.com',
+        private string $method = 'GET'
+    ) {
+    }
+
+    public function method(): string
+    {
+        return $this->method;
+    }
+
+    public function endpoint(): string
+    {
+        return $this->uri;
+    }
+}