hiapi\Core\Endpoint\Middleware\RepeatHandler

Complexity

Total Complexity

4

Size/Duplication

Total Lines	41
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

<?php
class RepeatHandler implements Middleware
{
    /** @var Middleware|callable */
    private $handler;

    public function __construct($handler)
    {
        $this->handler = $handler;
    }

    /**
     * @inheritDoc
     * @throws \Exception
     */
    public function execute($command, callable $next)
    {
        $this->ensureCommandIsIterable($command);
        $items = iterator_to_array($command, true);
        $res = array_map(function ($item) {
            return $this->handle($item);
        }, $items);

        return new ArrayCollection($res);
    }

    private function handle($item)
    {
        $handler = $this->handler;
        if (is_callable($handler)) {
            return $handler($item);
        } elseif ($handler instanceof Middleware) {
            return $handler->execute($item, fn ($command) => $command);

This code did not parse for me. Apparently, there is an error somewhere around this line:

Syntax error, unexpected T_DOUBLE_ARROW, expecting ',' or ')'

        }
        throw new \RuntimeException(sprintf(
            '%s expects handler to be closure or Middleware',
            self::class
        ));
    }

    private function ensureCommandIsIterable($command): void
    {
        if (!$command instanceof \IteratorAggregate) {