Add setCurlAmount and setRollingWindow setters to CurlEmitter

Author: matus-tomlein

src/Emitters/CurlEmitter.php

@@ -304,7 +304,16 @@ public function returnCurlBuffer() {
     }
 
     /**
-     * Returns the amount of curls we need before sending
+     * Set the amount of times we need to reach the buffer limit (buffer_size) before we initiate sending
+     * 
+     * @param int $curl_limit
+     */
+    public function setCurlAmount($curl_limit) {
+        $this->curl_limit = $curl_limit;
+    }
+
+    /**
+     * Returns the amount of times we need to reach the buffer limit (buffer_size) before we initiate sending
      *
      * @return int
      */
@@ -313,7 +322,16 @@ public function returnCurlAmount() {
     }
 
     /**
-     * Returns the amount of simultaneous curls we send
+     * Set the max amount of concurrent curl requests being made
+     * 
+     * @param int $rolling_window
+     */
+    public function setRollingWindow($rolling_window) {
+        $this->rolling_window = $rolling_window;
+    }
+
+    /**
+     * Returns the max amount of concurrent curl requests being made
      *
      * @return int
      */

tests/tests/EmitterTests/CurlEmitterTest.php

@@ -140,4 +140,22 @@ public function testReturnFunctions() {
         $this->assertEquals(10,
             $emitter->returnRollingWindow());
     }
+
+    public function testSetRollingWindow() {
+        $tracker = $this->returnTracker("POST", false, $this->uri);
+        $emitters = $tracker->returnEmitters();
+        $emitter = $emitters[0];
+
+        $emitter->setRollingWindow(32);
+        $this->assertEquals(32, $emitter->returnRollingWindow());
+    }
+
+    public function testSetCurlAmount() {
+        $tracker = $this->returnTracker("POST", false, $this->uri);
+        $emitters = $tracker->returnEmitters();
+        $emitter = $emitters[0];
+
+        $emitter->setCurlAmount(12);
+        $this->assertEquals(12, $emitter->returnCurlAmount());
+    }
 }