Railt\SDL\Frontend\Process

Complexity

Total Complexity

6

Size/Duplication

Total Lines	50
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	run()	0	8	2
A	await()	0	14	3

<?php
/**
 * This file is part of Railt package.
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */
declare(strict_types=1);

namespace Railt\SDL\Frontend;

use Railt\SDL\Frontend\Context\ContextInterface;
use Railt\SDL\Frontend\Interceptor\Factory;

/**
 * Class Process
 */
class Process
{
    /**
     * @var Factory
     */
    private $factory;

    /**
     * Process constructor.
     * @param Factory $factory
     */
    public function __construct(Factory $factory)
    {
        $this->factory = $factory;
    }

    /**
     * @param ContextInterface $ctx
     * @param mixed $result
     * @return array
     */
    public function run(ContextInterface $ctx, $result): array
    {
        if ($result instanceof \Generator) {
            return $this->await($ctx, $result);
        }

        return $this->factory->resolve($ctx, $result);
    }

    /**
     * @param ContextInterface $ctx
     * @param \Generator $process
     * @return array
     */
    public function await(ContextInterface $ctx, \Generator $process): array
    {
        while ($process->valid()) {
            [$ctx, $value] = $this->factory->resolve($ctx, $process->current());

The variable $value seems only to be defined at a later point. Did you maybe move this code here without moving the variable definition?

            $process->send($value);

The variable $value seems only to be defined at a later point. Did you maybe move this code here without moving the variable definition?

        }

        if ($value = $process->getReturn()) {
            return $this->factory->resolve($ctx, $value);
        }

        return [$ctx, $value];
    }
}