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/TaskHandler/ |
Upload File : |
<?php
declare(strict_types=1);
namespace GrumPHP\Runner\TaskHandler;
use Amp\Promise;
use Amp\Success;
use GrumPHP\Runner\TaskHandler\Middleware\TaskHandlerMiddlewareInterface;
use GrumPHP\Runner\TaskResult;
use GrumPHP\Runner\TaskResultInterface;
use GrumPHP\Runner\TaskRunnerContext;
use GrumPHP\Task\TaskInterface;
class TaskHandler
{
/**
* @var callable(TaskInterface, TaskRunnerContext): Promise<TaskResultInterface>
* @var callable
*/
private $stack;
public function __construct(TaskHandlerMiddlewareInterface ...$handlers)
{
$this->stack = $this->createStack($handlers);
}
/**
* Shortcut function to work directly with tagged services from the Symfony service container.
* @param iterable<TaskHandlerMiddlewareInterface> $handlers
*/
public static function fromIterable(iterable $handlers): self
{
return new self(
...($handlers instanceof \Traversable ? iterator_to_array($handlers) : $handlers)
);
}
/**
* @return Promise<TaskResultInterface>
*/
public function handle(TaskInterface $task, TaskRunnerContext $runnerContext): Promise
{
return ($this->stack)($task, $runnerContext);
}
/**
* @param TaskHandlerMiddlewareInterface[] $handlers
* @return callable(TaskInterface, TaskRunnerContext): Promise<TaskResultInterface>
*/
private function createStack(array $handlers): callable
{
$lastCallable = $this->fail();
while ($handler = array_pop($handlers)) {
$lastCallable = static function (
TaskInterface $task,
TaskRunnerContext $runnerContext
) use (
$handler,
$lastCallable
) : Promise {
return $handler->handle($task, $runnerContext, $lastCallable);
};
}
return $lastCallable;
}
/**
* @return callable(TaskInterface, TaskRunnerContext): Promise<TaskResultInterface>
*/
private function fail(): callable
{
return static function (TaskInterface $task, TaskRunnerContext $runnerContext): Promise {
/** @var TaskResultInterface $result */
$result = TaskResult::createFailed(
$task,
$runnerContext->getTaskContext(),
'Task could not be handled by a task handler!'
);
return new Success($result);
};
}
}