Junty\Runner\JuntyRunner::runTask()

Complexity

Conditions	7
Paths	10

Size

Total Lines	22
Code Lines	12

Duplication

Lines	0
Ratio	0 %

<?php
    public function runTask($task)
    {
        if (!is_string($task) && !$task instanceof TaskInterface) {
            throw JuntyException::invalidTaskType();
        }

        $tasks = $this->getTasks();

        if (is_string($task)) {
            if (!isset($tasks[$task])) {
                throw JuntyException::taskNotRegistred($task);
            }
        }

        $task = $task instanceof TaskInterface ? $task : $tasks[$task];
        $cb = \Closure::bind($task->getCallback(), new StreamHandler());
        $cb();

        if ($task->hasNext()) {
            $this->runTask($tasks[$task->getNext()]);
        }
    }
}