Delay valve

Author: dantleech

lib/Extension/Core/Stage/Sampler/CurlSampler.php

@@ -5,6 +5,7 @@
 use PhpBench\Pipeline\Core\Stage;
 use Generator;
 use PhpBench\Pipeline\Core\Schema;
+use PhpBench\Pipeline\Core\Signal;
 
 class CurlSampler implements Stage
 {
@@ -31,7 +32,7 @@ public function __invoke(): Generator
                 list($config, $data) = yield $info;
             }
 
-            usleep(10000);
+            yield Signal::continue();
         }
 
         curl_multi_close($this->multiHandle);

tests/Unit/Extension/Core/Stage/Valve/DelayValveTest.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace PhpBench\Pipeline\Tests\Unit\Extension\Core\Stage\Valve;
+
+use PhpBench\Pipeline\Tests\Unit\Extension\Core\CoreTestCase;
+
+class DelayValveTest extends CoreTestCase
+{
+    public function testDelaysExecution()
+    {
+        $start = microtime(true);
+        $this->pipeline()
+            ->stage('valve/delay', [ 'time' => 10000 ])
+            ->generator()
+            ->current();
+
+        $end = microtime(true);
+
+        $this->assertGreaterThan(10000, ($end - $start) * 1E6);
+    }
+}