hanneskod\readmetester\Runner\ParallelRunner

Complexity

Total Complexity

3

Size/Duplication

Total Lines	25
Duplicated Lines	0 %

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	setBootstrap()	0	3	1
A	run()	0	16	2

<?php

declare(strict_types=1);

namespace hanneskod\readmetester\Runner;

use hanneskod\readmetester\Attribute\Isolate;
use hanneskod\readmetester\Example\ExampleObj;

The type hanneskod\readmetester\Example\ExampleObj was not found. Maybe you did not declare it correctly or list all dependencies?

use hanneskod\readmetester\Example\ExampleStoreInterface;

use function Amp\Promise\wait;
use function Amp\ParallelFunctions\parallelMap;

final class ParallelRunner implements RunnerInterface
{
    private string $bootstrap = '';

    public function setBootstrap(string $filename): void
    {
        $this->bootstrap = $filename;
    }

    public function run(ExampleStoreInterface $exampleStore): iterable
    {
        $examples = $exampleStore->getExamples();

        if ($examples instanceof \Traversable) {
            $examples = iterator_to_array($examples, false);
        }

        // @phpstan-ignore-next-line
        return wait(
            parallelMap(
                $examples,

It seems like $examples can also be of type iterable; however, parameter $array of Amp\ParallelFunctions\parallelMap() does only seem to accept array, maybe add an additional type check?

                function (ExampleObj $example): OutcomeInterface {
                    $runner = new EvalRunner();
                    $runner->setBootstrap($this->bootstrap);
                    return $runner->runExample($example);
                }
            )
        );
    }
}