Ipl\IteratorPipeline\PipelineBuilder

Complexity

Total Complexity

5

Size/Duplication

Total Lines	69
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	with()	0	9	2
A	then()	0	6	1
A	__invoke()	0	3	1
A	setKeys()	0	7	1

<?php

declare(strict_types=1);

namespace Ipl\IteratorPipeline;

use Ipl\Iterator\CombineIterator;
use Ipl\IteratorPipeline\Traits\FilteringTrait;
use Ipl\IteratorPipeline\Traits\MappingTrait;
use Ipl\IteratorPipeline\Traits\SortingTrait;
use function Ipl\iterable_to_array;

/**
 * The `PipelineBuilder` can be used to create a blueprint for pipelines.
 */
class PipelineBuilder
{
    use MappingTrait;
    use FilteringTrait;
    use SortingTrait;

    /**
     * @var array
     */
    protected $steps = [];


    /**
     * Define the next step via a callback that returns an array or Traversable object.
     *
     * @param callable $callback
     * @param mixed    ...$args
     * @return static
     */
    public function then(callable $callback, ...$args): self
    {
        $copy = clone $this;
        $copy->steps[] = [$callback, $args];

        return $copy;
    }

    /**
     * Create a new pipeline
     *
     * @param iterable $iterable
     * @return Pipeline
     */
    public function with(iterable $iterable): Pipeline
    {
        $pipeline = new Pipeline($iterable);

        foreach ($this->steps as [$callback, $args]) {
            $pipeline->then($callback, ...$args);
        }

        return $pipeline;
    }

    /**
     * Invoke the builder.
     *
     * @param iterable $iterable
     * @return array
     */
    public function __invoke(iterable $iterable): array
    {
        return $this->with($iterable)->toArray();
    }


    /**
     * Use another iterator as keys and the current iterator as values.
     *
     * @param iterable $keys  Keys will be turned into an array.
     * @return static
     */
    public function setKeys(iterable $keys)
    {
        $combine = function ($values, $keys) {
            return new CombineIterator($keys, $values);
        };

        return $this->then($combine, iterable_to_array($keys));
    }
}