Stratadox\ObservationQueue\Queue

Complexity

Total Complexity

5

Size/Duplication

Total Lines	26
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	trigger()	0	4	2
A	add()	0	4	1
A	__construct()	0	3	1
A	process()	0	3	1

<?php

declare(strict_types=1);

namespace Stratadox\ObservationQueue;

use SplQueue;

class Queue implements QueuesObservations
{
    private $observations;

    public function __construct()
    {
        $this->observations = new SplQueue;
    }

    public function add($observer, string $method, ...$params) : void
    {
        $this->observations->enqueue(
            new Observation($observer, $method, ...$params)
        );
    }

    public function trigger() : void
    {
        while (!$this->observations->isEmpty()) {
            $this->process($this->observations->dequeue());
        }
    }

    private function process(Observation $observation) : void
    {
        $observation->trigger();
    }
}