Rewrote MiddlewareRunner to iterate over the array of middleware instead of creating a new instance of itself for each middleware ran

Author: WyriHaximus

src/MiddlewareRunner.php

@@ -11,8 +11,9 @@ final class MiddlewareRunner
 {
     /**
      * @var callable[]
+     * @internal
      */
-    private $middleware = array();
+    public $middleware = array();
 
     /**
      * @param callable[] $middleware
@@ -32,22 +33,34 @@ public function __invoke(ServerRequestInterface $request)
             return Promise\reject(new \RuntimeException('No middleware to run'));
         }
 
-        $middlewareCollection = $this->middleware;
-        $middleware = array_shift($middlewareCollection);
-
-        $cancel = null;
-        return new Promise\Promise(function ($resolve, $reject) use ($middleware, $request, $middlewareCollection, &$cancel) {
-            $cancel = $middleware(
-                $request,
-                new MiddlewareRunner(
-                    $middlewareCollection
-                )
-            );
-            $resolve($cancel);
-        }, function () use (&$cancel) {
-            if ($cancel instanceof Promise\CancellablePromiseInterface) {
-                $cancel->cancel();
-            }
-        });
+        $position = 0;
+
+        $that = $this;
+        $func = function (ServerRequestInterface $request) use (&$func, &$position, &$that) {
+            $middleware = $that->middleware[$position];
+            $response = null;
+            return new Promise\Promise(function ($resolve, $reject) use ($middleware, $request, $func, &$response, &$position) {
+                $position++;
+                try {
+                    $response = $middleware(
+                        $request,
+                        $func
+                    );
+                    $resolve($response);
+                } catch (\Exception $error) {
+                    $position--;
+                    $reject($error);
+                } catch (\Throwable $error) {
+                    $position--;
+                    $reject($error);
+                }
+            }, function () use (&$response) {
+                if ($response instanceof Promise\CancellablePromiseInterface) {
+                    $response->cancel();
+                }
+            });
+        };
+
+        return $func($request);
     }
-}
+}