dropping use of parallelMap()

spatie · Jan 3, 2024 · 4c12463 · 4c12463
1 parent edc4668
commit 4c12463
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 9 deletions.
diff --git a/composer.json b/composer.json
@@ -20,7 +20,6 @@
         "php": "^8.1",
         "amphp/amp": "^v3.0",
         "amphp/parallel": "^2.2",
-        "amphp/parallel-functions": "^2.0",
         "illuminate/collections": "^9.30|^10.0",
         "spatie/laravel-package-tools": "^1.4.3",
         "symfony/finder" : "^6.0|^7.0"

diff --git a/src/DiscoverWorkers/ParallelDiscoverWorker.php b/src/DiscoverWorkers/ParallelDiscoverWorker.php
@@ -2,11 +2,12 @@
 
 namespace Spatie\StructureDiscoverer\DiscoverWorkers;
 
-use function Amp\ParallelFunctions\parallelMap;
-use function Amp\Promise\wait;
+use function Amp\async;
+use function Amp\Future\await;
 
 use Illuminate\Support\Collection;
 use Spatie\StructureDiscoverer\Data\DiscoverProfileConfig;
+use function Amp\ParallelFunctions\parallelMap;
 
 class ParallelDiscoverWorker implements DiscoverWorker
 {
@@ -19,12 +20,9 @@ public function run(Collection $filenames, DiscoverProfileConfig $config): array
     {
         $sets = $filenames->chunk($this->filesPerJob)->toArray();
 
-        $promise = parallelMap(
-            $sets,
-            fn (array $set): array => $config->structureParser->execute($set)
-        );
-
-        $found = wait($promise);
+        $found = await(array_map(function ($set) use ($config) {
+            return async(fn () => $config->structureParser->execute($set));
+        }, $sets));
 
         return array_merge(...$found);
     }