anonymous//src/BusChain.php$0 ➔ dummyBus()

Complexity

Conditions

1

Size

Total Lines

5

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	BusChain.php$0 ➔ dispatch()	0	2	1

<?php
declare(strict_types=1);

namespace OniBus;

use InvalidArgumentException;

class BusChain implements Bus
{
    /**
     * @var Chain[]
     */
    protected $buses = [];

    public function __construct(Chain ...$buses)
    {
        if (empty($buses)) {
            throw new InvalidArgumentException('Bus Chain cannot be empty.');
        }

        $this->buses = $buses;
        $count = count($buses);
        for ($i = 0; $i < $count; $i++) {
            $nextBus = $this->buses[$i + 1] ?? $this->dummyBus();
            $this->buses[$i]->setNext($nextBus);
        }
    }

    protected function dummyBus(): Bus
    {
        return new class implements Bus {
            public function dispatch(Message $message)
            {
            }
        };
    }

    public function dispatch(Message $message)
    {
        return $this->buses[0]->dispatch($message);
    }
}