diff --git a/Worker.php b/Worker.php index 05b88bf..835c781 100644 --- a/Worker.php +++ b/Worker.php @@ -303,6 +303,7 @@ function execute($curls, $rolling_window) { } // Execute the rolling curl + $running = 0; do { $execrun = curl_multi_exec($master, $running); while ($execrun == CURLM_CALL_MULTI_PERFORM); diff --git a/src/Emitters/CurlEmitter.php b/src/Emitters/CurlEmitter.php index 32d6b52..21da6c4 100644 --- a/src/Emitters/CurlEmitter.php +++ b/src/Emitters/CurlEmitter.php @@ -173,6 +173,7 @@ private function rollingCurl($curls, $debug) { } // Execute the rolling curl + $running = 0; do { do { $execrun = curl_multi_exec($master, $running);