AlecRabbit\Spinner\Core\LoopSetup

Complexity

Total Complexity

10

Size/Duplication

Total Lines	39
Duplicated Lines	0 %

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	registerSignalHandlers()	0	4	2
A	setup()	0	8	5
A	signalHandlers()	0	7	1
A	registerAutoStart()	0	3	1

<?php

declare(strict_types=1);


namespace AlecRabbit\Spinner\Core;

use AlecRabbit\Spinner\Core\Contract\IDriver;
use AlecRabbit\Spinner\Core\Contract\ILoopSetup;
use AlecRabbit\Spinner\Core\Contract\Loop\Contract\ILoop;
use AlecRabbit\Spinner\Core\Settings\Contract\ILoopSettings;
use Traversable;

final class LoopSetup implements ILoopSetup
{
    public function __construct(
        protected ILoop $loop,
        protected ILoopSettings $settings,
    ) {
    }

    public function setup(IDriver $driver): void
    {
        if ($this->settings->isLoopAvailable()) {
            if ($this->settings->isAutoStartEnabled()) {
                $this->registerAutoStart();
            }
            if ($this->settings->isSignalProcessingAvailable() && $this->settings->isAttachHandlersEnabled()) {
                $this->registerSignalHandlers($driver);
            }
        }
    }

    private function registerAutoStart(): void
    {
        $this->loop->autoStart();
    }

    private function registerSignalHandlers(IDriver $driver): void
    {
        foreach ($this->signalHandlers($driver) as $signal => $handler) {
            $this->loop->onSignal($signal, $handler);

$handler of type array<integer,callable> is incompatible with the type Closure expected by parameter $closure of AlecRabbit\Spinner\Core\Contract\Loop\Contract\ILoop::onSignal().

        }
    }

    private function signalHandlers(IDriver $driver): Traversable
    {
        yield from [
            // @codeCoverageIgnoreStart
            SIGINT => function () use ($driver): void {
                $driver->interrupt(PHP_EOL . 'SIGINT' . PHP_EOL); // todo: test
                $this->loop->stop();
            },
            // @codeCoverageIgnoreEnd
        ];
    }
}