SlayerBirden\DataFlow\PipeLine

Complexity

Total Complexity

9

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

100%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	current()	0	4	1
A	insert()	0	15	4
A	next()	0	4	1
A	valid()	0	4	1
A	count()	0	4	1
A	rewind()	0	4	1

<?php
declare(strict_types=1);

namespace SlayerBirden\DataFlow;

class PipeLine implements PipeLineInterface, \Countable
{
    private $queue = [];
    private $pointer = 0;
    private $queueOrder = PHP_INT_MAX;

    public function current(): PipeInterface
    {
        return $this->queue[$this->pointer]['item'];
    }

    public function insert(PipeInterface $handler, int $priority = 0): void
    {
        $this->queue[] = [
            'item' => $handler,
            'p' => $priority,
            '_p' => $this->queueOrder--,
        ];
        usort($this->queue, function ($itemA, $itemB) {
            if ($itemA['p'] == $itemB['p']) {
                return ($itemA['_p'] > $itemB['_p']) ? -1 : 1;
            }

            return ($itemA['p'] > $itemB['p']) ? -1 : 1;
        });
    }

    public function next(): void
    {
        $this->pointer++;
    }

    public function valid(): bool
    {
        return isset($this->queue[$this->pointer]);
    }

    public function count(): int
    {
        return count($this->queue);
    }

    public function rewind(): void
    {
        $this->pointer = 0;
    }
}