Limit concurrency

turbo124 · Sep 9, 2022 · 4a0c9c6 · 4a0c9c6
1 parent ee2d8f1
commit 4a0c9c6
Showing 1 changed file with 19 additions and 2 deletions.
diff --git a/src/Generator.php b/src/Generator.php
@@ -106,17 +106,29 @@ public function batchFire($metric_array)
             $batch_of = 40;
             $batch = array_chunk($metric_array, $batch_of);
 
+			$x = 1;
+
             /* Concurrency ++ */
-            foreach($batch as $key => $value) {
+            foreach($batch as $key => $value) {	
 
             	$data['metrics'] = $value;
 
 				$promises = [
 				    $key => $client->requestAsync('POST',$this->endPoint($metric_array[0]->type), ['form_params' => $data])
 				];
+
+				$x++;
+
+				if($x >= 10) {
+					$x = 1;
+					$this->sendPromise($promises);
+				}
+
             }
 
-			$responses = Promise\Utils::unwrap($promises);
+			// $responses = Promise\Utils::unwrap($promises);
+
+
 
 		} catch (RequestException $e) {
 
@@ -125,6 +137,11 @@ public function batchFire($metric_array)
 
 	}
 
+	private function sendPromise($promises)
+	{
+		$responses = Promise\Utils::unwrap($promises);
+		// $responses = Promise\Utils::settle($promises)->wait();
 
+	}
 
 }