Nexus\SynchronousProcessor

Complexity

Total Complexity

7

Size/Duplication

Total Lines	21
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	process()	0	12	6

<?php

declare(strict_types=1);

namespace Nexus;

use Nexus\Exceptions\TaskResultViolation;
use Psr\EventDispatcher\ListenerProviderInterface;
use Psr\EventDispatcher\StoppableTaskInterface;
use Psr\EventDispatcher\TaskInterface;
use Psr\EventDispatcher\TaskProcessorInterface;

class SynchronousProcessor implements TaskProcessorInterface
{
    private $listenerProvider;

    public function __construct(ListenerProviderInterface $listenerProvider)
    {
        $this->listenerProvider = $listenerProvider;
    }

    public function process(TaskInterface $task): TaskInterface
    {
        foreach ($this->listenerProvider->getListenersForEvent($task) as $listener) {
            $task = call_user_func($listener, $task);
            if (!is_object($task) || !($task instanceof TaskInterface)) {
                throw new TaskResultViolation();
            }
            if ($task instanceof StoppableTaskInterface && $task->isPropagationStopped()) {
                break;
            }
        }
        return $task;
    }
}