Tarantool\JobQueue\Executor\ExecutorChain

Complexity

Total Complexity

6

Size/Duplication

Total Lines	34
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	2
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	2
A	execute()	0	13	3
A	add()	0	5	1

<?php

namespace Tarantool\JobQueue\Executor;

use Tarantool\JobQueue\Exception\BadPayloadException;
use Tarantool\Queue\Queue;

class ExecutorChain implements Executor
{
    /**
     * @var Executor[]
     */
    private $executors;

    public function __construct(array $executors = [])
    {
        foreach ($executors as $executor) {
            $this->add($executor);
        }
    }

    public function add(Executor $executor): self
    {
        $this->executors[] = $executor;

        return $this;
    }

    public function execute($payload, Queue $queue): void
    {
        foreach ($this->executors as $executor) {
            try {
                $executor->execute($payload, $queue);

                return;
            } catch (BadPayloadException $e) {
                // try next executor
            }
        }

        throw new BadPayloadException($payload);
    }
}