Server : ApacheSystem : Linux host.digitalbabaji.in 4.18.0-513.11.1.el8_9.x86_64 #1 SMP Wed Jan 17 02:00:40 EST 2024 x86_64 User : addictionfreeind ( 1003) PHP Version : 7.2.34 Disable Function : exec,passthru,shell_exec,system Directory : /home/addictionfreeind/www/admin1/vendor/phpro/grumphp/src/Runner/Promise/ |
Upload File : |
<?php
declare(strict_types=1);
namespace GrumPHP\Runner\Promise;
use Amp\CancellationTokenSource;
use Amp\CancelledException;
use Amp\Deferred;
use Amp\Loop;
use Amp\Promise;
use Amp\LazyPromise;
use function Amp\Promise\any;
class MultiPromise
{
/**
* @template TValue
*
* @param array<int, LazyPromise<TValue>> $promises
* @param callable(TValue):bool $shouldCancel
*
* @return Promise<array{0: \Throwable[], 1: TValue[]}>
*/
public static function cancelable(array $promises, callable $shouldCancel): Promise
{
$tokenSource = new CancellationTokenSource();
return any(
array_map(
static function (LazyPromise $promise) use ($tokenSource, $shouldCancel) : Promise {
$deferred = new Deferred();
Loop::defer(
static function (string $watcherId) use (
$tokenSource,
$shouldCancel,
$deferred,
$promise
): void {
$tokenSource->getToken()->subscribe(
static function (CancelledException $error) use ($deferred, $watcherId): void {
$deferred->fail($error);
Loop::cancel($watcherId);
}
);
$cancel = static function (?\Throwable $error = null) use ($tokenSource): void {
Loop::defer(function () use ($tokenSource, $error) {
$tokenSource->cancel($error);
});
};
$promise->onResolve(
/**
* @param TValue $result
*/
static function (
?\Throwable $error,
$result
) use (
$deferred,
$cancel,
$shouldCancel
): void {
if ($error instanceof \Throwable) {
$cancel($error);
$deferred->fail($error);
return;
}
if ($result && $shouldCancel($result)) {
$cancel();
}
$deferred->resolve($result);
}
);
}
);
return $deferred->promise();
},
$promises
)
);
}
}