add multiGet and multiPost

tests/Feature/HttpTest.php

@@ -16,6 +16,18 @@ use Tests\TestCaseBase;
 
 class HttpTest extends TestCaseBase
 {
+    protected $urls;
+
+    public function setUp()
+    {
+        $this->urls = [
+            'http://httpbin.org/get?name=php',
+            'http://httpbin.org/get?name=golang',
+            'http://httpbin.org/get?name=c++',
+            'http://httpbin.org/get?name=java'
+        ];
+    }
+
     /**
      * @test
      */
@@ -34,8 +46,43 @@ class HttpTest extends TestCaseBase
     /**
      * @test
      */
-    public function concurrent_requests()
+    public function concurrent_requests_base_use()
     {
-        
+        $urls = $this->urls;
+        QueryList::getInstance()
+            ->multiGet($urls)
+            ->success(function(QueryList $ql,Response $response, $index) use($urls){
+                $body = json_decode((string)$response->getBody(),true);
+                $this->assertEquals($urls[$index],$body['url']);
+            })->send();
+    }
+
+    /**
+     * @test
+     */
+    public function concurrent_requests_advanced_use()
+    {
+        $ua = 'QueryList/4.0';
+
+        $errorUrl = 'http://web-site-not-exist.com';
+        $urls = array_merge($this->urls,[$errorUrl]);
+
+        QueryList::rules([])
+            ->multiGet($urls)
+            ->concurrency(2)
+            ->withOptions([
+                'timeout' => 60
+            ])
+            ->withHeaders([
+                'User-Agent' => $ua
+            ])
+            ->success(function (QueryList $ql, Response $response, $index) use($ua){
+                $body = json_decode((string)$response->getBody(),true);
+                $this->assertEquals($ua,$body['headers']['User-Agent']);
+            })
+            ->error(function (QueryList $ql, $reason, $index) use($urls,$errorUrl){
+                $this->assertEquals($urls[$index],$errorUrl);
+            })
+            ->send();
     }
 }