Spatie\CollectionMacros\Macros\ParallelMap

Complexity

Total Complexity

3

Size/Duplication

Total Lines	30
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	parallelMap()	0	18	3

<?php

namespace Spatie\CollectionMacros\Macros;

use Amp\Parallel\Worker\Pool;
use function Amp\Promise\wait;
use Illuminate\Support\Collection;
use Amp\Parallel\Worker\DefaultPool;
use function Amp\ParallelFunctions\parallelMap;

This use statement conflicts with another class in this namespace, Spatie\CollectionMacros\Macros\parallelMap.

class ParallelMap
{
    /**
     * Identical to map but each item will be processed in parallel.
     *
     * This function requires the installation of amphp/parallel-functions
     *
     * @param callable $callback

There is no parameter named $callback. Was it maybe removed?

     *
     * @return \Illuminate\Support\Collection
     */
    public function parallelMap()
    {
        return function (callable $callback, $workers = null): Collection {
            $pool = null;

            if ($workers instanceof Pool) {
                $pool = $workers;
            }

            if (is_int($workers)) {
                $pool = new DefaultPool($workers);
            }

            $promises = parallelMap($this->items, $callback, $pool);

The property items does not exist. Did you maybe forget to declare it?

            return new static(wait($promises));

The call to ParallelMap::__construct() has too many arguments starting with \Amp\Promise\wait($promises).

        };
    }
}