AlecRabbit\Spinner\Asynchronous\React\ReactLoopAdapter

Complexity

Total Complexity

9

Size/Duplication

Total Lines	49
Duplicated Lines	0 %

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	stop()	0	3	1
A	delay()	0	3	1
A	repeat()	0	3	1
A	onSignal()	0	3	1
A	__construct()	0	3	1
A	cancel()	0	12	2
A	autoStart()	0	2	1
A	run()	0	3	1

<?php

declare(strict_types=1);

namespace AlecRabbit\Spinner\Asynchronous\React;

use AlecRabbit\Spinner\Core\Loop\Contract\A\ALoopAdapter;
use AlecRabbit\Spinner\Exception\InvalidArgument;
use Closure;
use React\EventLoop\LoopInterface;
use React\EventLoop\TimerInterface;

/**
 * @codeCoverageIgnore
 */
final class ReactLoopAdapter extends ALoopAdapter
{
    public function __construct(
        private readonly LoopInterface $loop,
    ) {
    }

    public function autoStart(): void
    {
        // ReactPHP event loop is started by its library code.
    }

    public function repeat(float $interval, Closure $closure): TimerInterface
    {
        return $this->loop->addPeriodicTimer($interval, $closure);
    }

    public function delay(float $delay, Closure $closure): void
    {
        $this->loop->addTimer($delay, $closure);
    }

    public function run(): void
    {
        $this->loop->run();
    }

    public function stop(): void
    {
        $this->loop->stop();
    }

    public function cancel(mixed $timer): void
    {
        if (!$timer instanceof TimerInterface) {
            throw new InvalidArgument(
                sprintf(
                    'Invalid timer type: %s, expected %s',
                    gettype($timer),
                    TimerInterface::class
                )
            );
        }
        $this->loop->cancelTimer($timer);
    }

    public function onSignal(int $signal, Closure $closure): void
    {
        $this->loop->addSignal($signal, $closure);
    }
}