Dock\IO\Process\WaitStrategy\TimeoutWait

Complexity

Total Complexity

5

Size/Duplication

Total Lines	42
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	wait()	0	16	4

<?php

namespace Dock\IO\Process\WaitStrategy;

use Symfony\Component\Process\Process;

class TimeoutWait implements WaitStrategy
{
    const TICK = 100;

    /**
     * Timeout, in milliseconds.
     *
     * @var int
     */
    private $timeout;

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

    public function __construct($timeout, callable $callback)
    {
        $this->timeout = $timeout;
        $this->callback = $callback;
    }

    /**
     * {@inheritdoc}
     */
    public function wait(Process $process)
    {
        $start = microtime(true);
        $end = $start + $this->timeout / 1000;

        while (!$process->isTerminated() && (microtime(true) < $end)) {
            usleep(self::TICK * 1000);
        }

        if ($process->isRunning()) {
            $callback = $this->callback;
            $callback();
        }

        $process->wait();
    }
}