Antidot\React\ResolveGenerator

Complexity

Total Complexity

5

Size/Duplication

Total Lines	28
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	1

1 Method

Rating	Name	Duplication	Size	Complexity
A	toResponse()	0	23	5

<?php

declare(strict_types=1);

namespace Antidot\React;

use Generator;
use Psr\Http\Message\ResponseInterface;
use React\Promise\Promise;
use React\Promise\PromiseInterface;
use Throwable;

final class ResolveGenerator
{
    /**
     * @param callable<Generator>|ResponseInterface|PromiseInterface $generator
     */
    public static function toResponse(
        callable|ResponseInterface|PromiseInterface $callback
    ): PromiseInterface|ResponseInterface {
        if (false === is_callable($callback)) {
            return $callback;

The expression return $callback could return the type callable which is incompatible with the type-hinted return Psr\Http\Message\ResponseInterface|React\Promise\PromiseInterface. Consider adding an additional type-check to rule them out.

        }

        return new Promise(
            static function (callable $resolve, callable $reject) use ($callback): void {
                try {
                    /** @var Generator<PromiseInterface|ResponseInterface> $generator */
                    $generator = $callback();
                    while ($generator->valid()) {
                        $item = $generator->current();
                        if ($item instanceof PromiseInterface) {
                            $item->then(static fn($solved) => $generator->send($solved));
                            continue;
                        }
                        $generator->send($item);
                    }
                    $resolve($generator->getReturn());
                } catch (Throwable $exception) {
                    $reject($exception);
                }
            }
        );
    }
}