Added async calls

Author: Nyholm

tests/Plugin/AddPathPluginTest.php

@@ -4,7 +4,10 @@
 
 use Http\Client\Common\Plugin;
 use Http\Client\Common\Plugin\AddPathPlugin;
+use Http\Client\Common\PluginClient;
+use Http\Client\HttpClient;
 use Nyholm\Psr7\Request;
+use Nyholm\Psr7\Response;
 use Nyholm\Psr7\Uri;
 use PHPUnit\Framework\TestCase;
 use Psr\Http\Message\RequestInterface;
@@ -44,7 +47,7 @@ public function testRewriteSameUrl()
         $this->plugin->handleRequest($request, $verify, $this->callable);
     }
 
-    public function testRewriteOnRestart()
+    public function testRewriteCallingThePluginTwice()
     {
         $request = new Request('GET', 'https://example.com/foo');
         $this->plugin->handleRequest($request, function (RequestInterface $request) {
@@ -82,4 +85,52 @@ public function testRewriteWithDifferentUrlWhenSecondUrlIncludesAddedPath()
         $request = new Request('GET', 'https://example.com/api/foo');
         $this->plugin->handleRequest($request, $verify, $this->callable);
     }
+
+    public function testRewriteWhenPathIsIncluded()
+    {
+        $verify = function (RequestInterface $request) {
+            $this->assertEquals('https://example.com/api/api/foo', $request->getUri()->__toString());
+        };
+
+        $request = new Request('GET', 'https://example.com/api/foo');
+        $this->plugin->handleRequest($request, $verify, $this->callable);
+    }
+    public function testRewriteOnRestart()
+    {
+        $secondPlugin = new class implements Plugin {
+            private $firstRun = true;
+
+            public function handleRequest(RequestInterface $request, callable $next, callable $first)
+            {
+                if ($this->firstRun) {
+                    $this->firstRun = false;
+                    return $first($request)->wait();
+                }
+                return $next($request);
+            }
+        };
+
+        $verify = function (RequestInterface $request) {
+            $this->assertEquals('https://example.com/api/foo', $request->getUri()->__toString());
+        };
+
+        $client = new class($verify) implements HttpClient {
+            private $callable;
+            public function __construct(callable $callable)
+            {
+                $this->callable = $callable;
+            }
+
+            public function sendRequest(RequestInterface $request)
+            {
+                $verify = $this->callable;
+                $verify($request);
+                return new Response();
+            }
+        };
+
+        $pluginClient = new PluginClient($client, [$this->plugin, $secondPlugin]);
+        $request = new Request('GET', 'https://example.com/foo');
+        $response = $pluginClient->sendAsyncRequest($request);
+    }
 }