Fix dynamic concurrency in example

amphp · Aug 22, 2023 · 943352b · 943352b
1 parent 5288d3c
commit 943352b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/examples/ffmpeg.php b/examples/ffmpeg.php
@@ -11,7 +11,7 @@
 $start = microtime(true);
 
 Pipeline::fromIterable(new DirectoryIterator('.'))
-    ->concurrent(3)
+    ->concurrent($concurrency)
     ->filter(fn ($item) => $item->getExtension() === 'mkv')
     ->map(fn ($item) => createVideoClip($ffmpeg, $item->getPathname(), getTempDestination()))
     ->forEach(fn ($result) => getStdout()->write('Successfully created clip from ' . $result[0] . ' => ' . $result[1] . PHP_EOL));