OniBus\Buses\ProtectOrder::dispatch()

Complexity

Conditions	3
Paths	2

Size

Total Lines	16
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function dispatch(Message $message)
    {
        $this->queue[] = $message;
        $lastResult = null;

        if (!$this->isDispatching) {
            $this->isDispatching = true;

            while ($message = array_shift($this->queue)) {
                $lastResult = $this->next($message);
            }

            $this->isDispatching = false;
        }

        return $lastResult;
    }