update to PHP-8.1

[m6w6/seekat] / lib / API / Future / functions.php

diff --git a/lib/API/Future/functions.php b/lib/API/Future/functions.php
index 3cddb221b06c1188713a7e9065cc9f3b7bed397d..d2a92329133eca4acc56bc61c52b4ad2dbc9fdee 100644 (file)
--- a/lib/API/Future/functions.php
+++ b/lib/API/Future/functions.php
@@ -2,173 +2,22 @@
 
 namespace seekat\API\Future;
 
-use Amp\Deferred as AmpDeferred;
-use Amp\Promise as AmpPromise;
-use React\Promise\Deferred as ReactDeferred;
-use React\Promise\PromiseInterface as ReactPromise;
 use seekat\API\Future;
 
-/**
- * @param Future $future
- * @param mixed $value
- * @return mixed promise
- */
-function resolve(Future $future, $value) {
-       $promisor = $future->createContext();
-       $future->resolve($promisor, $value);
-       return $future->getPromise($promisor);
+function react() : React2 {
+       return new React2;
 }
 
-/**
- * @param Future $future
- * @param mixed $reason
- * @return mixed promise
- */
-function reject(Future $future, $reason) {
-       $promisor = $future->createContext();
-       $future->reject($promisor, $reason);
-       return $future->getPromise($promisor);
+function amp() : Amp2 {
+       return new Amp2;
 }
 
-/**
- * @param Future $future
- * @param mixed $context Promisor
- * @return \Closure
- */
-function resolver(Future $future, $context) {
-       return function($value) use($future, $context) {
-               $future->resolve($context, $value);
-       };
-}
-
-/**
- * @param Future $future
- * @param mixed $context Promisor
- * @return \Closure
- */
-function rejecter(Future $future, $context) {
-       return function($reason) use($future, $context) {
-               $future->reject($context, $reason);
-       };
-}
-
-/**
- * @param Future $future
- * @param mixed $context Promisor
- * @return \Closure
- */
-function reducer(Future $future, $context) {
-       return function(array $promises) use($future, $context) {
-               return $future->all($context, $promises);
-       };
-}
-
-/**
- * @return Future
- */
-function react() {
-       return new class implements Future {
-               /**
-                * @param callable|null $onCancel
-                * @return ReactDeferred
-                */
-               function createContext(callable $onCancel = null) {
-                       return new ReactDeferred($onCancel);
-               }
-
-               function getPromise($context) {
-                       /* @var $context ReactDeferred */
-                       return $context->promise();
-               }
-
-               function isPromise($promise) : bool {
-                       return $promise instanceof ReactPromise;
-               }
-
-               function handlePromise($promise, callable $onResult = null, callable $onError = null) {
-                       return $promise->then($onResult, $onError);
-               }
-
-               function cancelPromise($promise) {
-                       /* @var $promise \React\Promise\Promise */
-                       $promise->cancel();
-               }
-
-               function resolve($context, $value) {
-                       /* @var $context ReactDeferred */
-                       $context->resolve($value);
-               }
-
-               function reject($context, $reason) {
-                       /* @var $context ReactDeferred */
-                       $context->reject($reason);
-               }
-
-               function all($context, array $promises) {
-                       return \React\Promise\all($promises);
-               }
-       };
-}
-
-/**
- * @return Future
- */
-function amp() {
-       return new class implements Future {
-               /**
-                * @return AmpDeferred
-                */
-               function createContext(callable $onCancel = null) {
-                       $context = new AmpDeferred();
-                       /** @noinspection PhpUndefinedFieldInspection */
-                       $context->promise()->cancel = function() use($onCancel, $context) {
-                               $onCancel();
-                       };
-                       return $context;
-               }
-
-               function getPromise($context) {
-                       /* @var $context AmpDeferred */
-                       return $context->promise();
-               }
-
-               function isPromise($promise) : bool {
-                       return $promise instanceof AmpPromise;
-               }
-
-               function handlePromise($promise, callable $onResult = null, callable $onError = null) {
-                       $promise->onResolve(function($error = null, $result = null) use($onResult, $onError) {
-                               if ($error) {
-                                       if ($onError) {
-                                               $onError($error);
-                                       }
-                               } else {
-                                       if ($onResult) {
-                                               $onResult($result);
-                                       }
-                               }
-                       });
-                       return $promise;
-               }
-
-               function cancelPromise($promise) {
-                       /** @var $promise AmpPromise */
-                       /** @noinspection PhpUndefinedFieldInspection */
-                       ($promise->cancel)();
-               }
-
-               function resolve($context, $value) {
-                       /* @var $context AmpDeferred */
-                       $context->resolve($value);
-               }
-
-               function reject($context, $reason) {
-                       /* @var $context AmpDeferred */
-                       $context->fail(\seekat\Exception\exception($reason));
-               }
-
-               function all($context, array $promises) {
-                       return \Amp\Promise\all($promises);
-               }
-       };
+function any() : Amp2|React2 {
+       if (interface_exists(\Amp\Promise::class, true)) {
+               return amp();
+       }
+       if (interface_exists(\React\Promise\PromiseInterface::class, true)) {
+               return react();
+       }
+       throw new \Exception("Cannot find any promise implementation");
 }