mpyw\Co\Internal\Delayer

Complexity

Total Complexity

15

Size/Duplication

Total Lines	82
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	add()	0	15	4
B	sleep()	0	18	6
A	consumeAndResolve()	0	12	4
A	isEmpty()	0	4	1

<?php

namespace mpyw\Co\Internal;
use mpyw\RuntimePromise\Deferred;

class Delayer
{
    /**
     * Delays to be ended at.
     * @var array
     */
    private $untils = [];

    /**
     * Deferreds.
     * @var Deferred
     */
    private $deferreds = [];

    /**
     * Add delay.
     * @param int      $time
     * @param Deferred $deferred
     */
    public function add($time, Deferred $deferred)
    {
        $time = filter_var($time, FILTER_VALIDATE_FLOAT);
        if ($time === false) {
            throw new \InvalidArgumentException('Delay must be number.');
        }
        if ($time < 0) {
            throw new \DomainException('Delay must be positive.');
        }
        do {
            $id = uniqid();
        } while (isset($this->untils[$id]));
        $this->untils[$id] = microtime(true) + $time;
        $this->deferreds[$id] = $deferred;
    }

    /**
     * Sleep at least required.
     */
    public function sleep()
    {
        $now = microtime(true);
        $min = null;
        foreach ($this->untils as $id => $until) {
            $diff = $until - $now;
            if ($diff < 0) {
                // @codeCoverageIgnoreStart
                return;
                // @codeCoverageIgnoreEnd
            }
            if ($min !== null && $diff >= $min) {
                continue;
            }
            $min = $diff;
        }
        $min && usleep($min * 1000000);
    }

    /**
     * Consume delay queue.
     */
    public function consumeAndResolve()
    {
        foreach ($this->untils as $id => $until) {
            $diff = $until - microtime(true);
            if ($diff > 0.0 || !isset($this->deferreds[$id])) {
                continue;
            }
            $deferred = $this->deferreds[$id];
            unset($this->deferreds[$id], $this->untils[$id]);
            $deferred->resolve(null);
        }
    }

    /**
     * Is $untils empty?
     * @return bool
     */
    public function isEmpty()
    {
        return !$this->untils;
    }
}