AlecRabbit\Spinner\Asynchronous\Factory\A\ALoopFactory

Complexity

Total Complexity

7

Size/Duplication

Total Lines	33
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	getProbeClasses()	0	4	1
A	create()	0	6	2
A	createLoopAdapter()	0	12	4

<?php

declare(strict_types=1);

namespace AlecRabbit\Spinner\Asynchronous\Factory\A;

use AlecRabbit\Spinner\Contract\IProbe;
use AlecRabbit\Spinner\Core\Contract\ILoopAdapter;
use AlecRabbit\Spinner\Core\Contract\ILoopProbe;
use AlecRabbit\Spinner\Core\Factory\A\ADefaultsAwareClass;
use AlecRabbit\Spinner\Core\Factory\Contract\ILoopFactory;
use AlecRabbit\Spinner\Core\Factory\DefaultsFactory;
use AlecRabbit\Spinner\Mixin\NoInstanceTrait;
use DomainException;
use Traversable;

abstract class ALoopFactory extends ADefaultsAwareClass implements ILoopFactory
{
    use NoInstanceTrait;

    protected static ?ILoopAdapter $loop = null;

    final public static function create(): ILoopAdapter
    {
        if (static::$loop instanceof ILoopAdapter) {
            return static::$loop;
        }
        return static::createLoopAdapter();
    }

    protected static function createLoopAdapter(): ILoopAdapter
    {
        /** @var class-string<IProbe> $probe */
        foreach (static::getProbeClasses() as $probe) {
            if (is_subclass_of($probe, ILoopProbe::class) && $probe::isSupported()) {
                return $probe::createLoop();
            }
        }
        throw new DomainException(
            'No supported event loop found.' .
            ' Check you have installed one of the supported event loops.' .
            ' Check your probes list if you have modified it.'
        );
    }

    protected static function getProbeClasses(): Traversable
    {
        return
            DefaultsFactory::get()->getProbeClasses();
    }
}