Update benchmark example

amphp · May 11, 2017 · fbf4b2e · fbf4b2e · kelunik · May 12, 2017
1 parent cfbf25e
commit fbf4b2e
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/examples/benchmark-throughput.php b/examples/benchmark-throughput.php
@@ -38,12 +38,15 @@
 
 $stderr->write('piping from ' . $if . ' to ' . $of . ' (for max ' . $t . ' second(s)) ...'. PHP_EOL);
 
-Loop::delay($t * 1000, [$in, "close"]);
+$running = true;
+Loop::delay($t * 1000, function () use (&$running) {
+    $running = false;
+});
 
-Loop::run(function () use ($stderr, $in, $out) {
+Loop::run(function () use (&$running, $stderr, $in, $out) {
     $start = microtime(true);
 
-    while (($chunk = yield $in->read()) !== null) {
+    while ($running && ($chunk = yield $in->read()) !== null) {
         yield $out->write($chunk);
     }