OniBus\ChainTrait

Complexity

Total Complexity

4

Size/Duplication

Total Lines	31
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	next()	0	9	2
A	hasNext()	0	3	1
A	setNext()	0	3	1

<?php
declare(strict_types=1);

namespace OniBus;

use RuntimeException;

trait ChainTrait
{
    /**
     * @var Bus|null
     */
    protected $nextBus = null;

    public function setNext(Bus $bus)
    {
        $this->nextBus = $bus;
    }

    /**
     * @param Message $message
     * @return mixed
     * @throws RuntimeException
     */
    protected function next(Message $message)
    {
        if (!$this->hasNext()) {
            throw new RuntimeException(
                sprintf("[%s] The next Bus was not defined in the chain.", get_class($this))
            );
        }

        return $this->nextBus->dispatch($message);
    }

    protected function hasNext(): bool
    {
        return $this->nextBus instanceof Bus;
    }
}