Dazzle\Loop\Tick\TickContinousQueue

Complexity

Total Complexity

7

Size/Duplication

Total Lines	72
Duplicated Lines	100 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	5	5	1
A	__destruct()	5	5	1
A	add()	4	4	1
A	tick()	9	9	3
A	isEmpty()	4	4	1

<?php

namespace Dazzle\Loop\Tick;

use Dazzle\Loop\LoopModelInterface;
use SplQueue;

class TickContinousQueue

This class seems to be duplicated in your project.

{
    /**
     * @var LoopModelInterface
     */
    protected $loop;

    /**
     * @var SplQueue
     */
    protected $queue;

    /**
     * @var callable
     */
    private $callback;

    /**
     * @param LoopModelInterface $loop
     */
    public function __construct(LoopModelInterface $loop)
    {
        $this->loop = $loop;
        $this->queue = new SplQueue();
    }

    /**
     *
     */
    public function __destruct()
    {
        unset($this->loop);
        unset($this->queue);
    }

    /**
     * Add a callback to be invoked on the next tick of the event loop.
     *
     * Callbacks are guaranteed to be executed in the order they are enqueued, before any timer or stream events.
     *
     * @param callable $listener
     */
    public function add(callable $listener)
    {
        $this->queue->enqueue($listener);
    }

    /**
     * Flush the callback queue.
     *
     * Invokes callbacks which were on the queue when tick() was called and newly added ones.
     */
    public function tick()
    {
        while (!$this->queue->isEmpty() && $this->loop->isRunning())
        {
            $this->callback = $this->queue->dequeue();
            $callback = $this->callback; // without this proxy PHPStorm marks line as fatal error.
            $callback($this->loop);
        }
    }

    /**
     * Check if the next tick queue is empty.
     *
     * @return boolean
     */
    public function isEmpty()
    {
        return $this->queue->isEmpty();
    }
}