Merge pull request #6 from reactphp-parallel/template-types-with-async-await-API

Template types with async/await API

Author: WyriHaximus

composer.json

@@ -11,7 +11,6 @@
     ],
     "require": {
         "php": "^8.2",
-        "react/promise": "^3",
         "wyrihaximus/pool-info": "^2"
     },
     "require-dev": {

composer.lock

@@ -5,20 +5,19 @@
 namespace ReactParallel\Contracts;
 
 use Closure;
-use React\Promise\PromiseInterface;
 use WyriHaximus\PoolInfo\PoolInfoInterface;
 
 interface PoolInterface extends PoolInfoInterface
 {
     /**
-     * @param (Closure():(PromiseInterface<T>|T)) $callable
-     * @param array<mixed>                        $args
+     * @param (Closure():T) $callable
+     * @param array<mixed>  $args
      *
-     * @return PromiseInterface<T>
+     * @return T
      *
      * @template T
      */
-    public function run(Closure $callable, array $args = []): PromiseInterface;
+    public function run(Closure $callable, array $args = []): mixed;
 
     /**
      * Gently close every thread in the pool.

src/PoolInterface.php

@@ -5,11 +5,8 @@
 namespace ReactParallel\Tests\Contracts;
 
 use Closure;
-use React\Promise\PromiseInterface;
 use WyriHaximus\PoolInfo\PoolInfoInterface;
 
-use function React\Promise\resolve;
-
 final class MockPool implements PoolInfoInterface
 {
     /** @return iterable<string, int> */
@@ -19,16 +16,16 @@ public function info(): iterable
     }
 
     /**
-     * @param (Closure():(PromiseInterface<T>|T)) $callable
-     * @param array<mixed>                        $args
+     * @param (Closure():T) $callable
+     * @param array<mixed>  $args
      *
-     * @return PromiseInterface<T>
+     * @return T
      *
      * @template T
      */
-    public function run(Closure $callable, array $args = []): PromiseInterface
+    public function run(Closure $callable, array $args = []): mixed
     {
-        return resolve($callable(...$args));
+        return $callable(...$args);
     }
 
     public function close(): bool

tests/MockPool.php

@@ -8,10 +8,10 @@
 
 $pool = new MockPool();
 
-assertType('React\Promise\PromiseInterface<bool>', $pool->run(static function (): bool {
+assertType('bool', $pool->run(static function (): bool {
     return true;
 }));
 
-assertType('React\Promise\PromiseInterface<bool|int>', $pool->run(static function (): bool|int {
+assertType('bool|int', $pool->run(static function (): bool|int {
     return time() % 2 !== 0 ? true : time();
 }));