改名

http-handler/Abstracts/Handler.php

@@ -12,23 +12,21 @@ use Psr\Http\Message\ResponseInterface;
 use Psr\Http\Message\ServerRequestInterface;
 use Psr\Http\Server\MiddlewareInterface;
 use Psr\Http\Server\RequestHandlerInterface;
+use Swoole\Coroutine\Iterator;
 
 
 abstract class Handler implements RequestHandlerInterface
 {
 
 
-    private int $offset = 0;
-
-
     protected AspectProxy $aspectProxy;
 
 
     /**
-     * @param \Http\Handler\Handler $handler
-     * @param array|null $middlewares
+     * @param CHl $handler
+     * @param Iterator $middlewares
      */
-    public function __construct(public CHl $handler, public ?array $middlewares)
+    public function __construct(public CHl $handler, public Iterator $middlewares)
     {
         $this->aspectProxy = Kiri::getDi()->get(AspectProxy::class);
     }
@@ -41,16 +39,15 @@ abstract class Handler implements RequestHandlerInterface
      */
     protected function execute(ServerRequestInterface $request): ResponseInterface
     {
-        if (empty($this->middlewares) || !isset($this->middlewares[$this->offset])) {
+		$middleware = $this->middlewares->current();
+        if (empty($middleware)) {
             return $this->dispatcher($request);
         }
+	    if (!($middleware instanceof MiddlewareInterface)) {
+		    throw new \Exception('get_implements_class($middleware) not found method process.');
+	    }
 
-        $middleware = $this->middlewares[$this->offset];
-        if (!($middleware instanceof MiddlewareInterface)) {
-            throw new \Exception('get_implements_class($middleware) not found method process.');
-        }
-
-        ++$this->offset;
+        $this->middlewares->next();
 
         return $middleware->process($request, $this);
     }

http-handler/Abstracts/MiddlewareManager.php

@@ -38,11 +38,12 @@ class MiddlewareManager extends BaseObject
 		if (is_string($middlewares)) {
 			$middlewares = [$middlewares];
 		}
+		$source = &static::$_middlewares[$class][$method];
 		foreach ($middlewares as $middleware) {
-			if (isset(static::$_middlewares[$class][$method][$middleware])) {
+			if (isset($source[$middleware])) {
 				continue;
 			}
-			static::$_middlewares[$class][$method][$middleware] = di($middleware);
+			$source[$middleware] = di($middleware);
 		}
 		return true;
 	}

http-server/Service/Http.php

@@ -16,6 +16,7 @@ use Http\Message\Stream;
 use Kiri\Abstracts\Config;
 use Kiri\Exception\ConfigException;
 use Kiri\Kiri;
+use Kiri\Pool\Helper\SplQueue;
 use Psr\Http\Message\ServerRequestInterface;
 use Server\Abstracts\Utility\EventDispatchHelper;
 use Server\Abstracts\Utility\ResponseHelper;
@@ -28,6 +29,7 @@ use Server\ExceptionHandlerInterface;
 use Server\SInterface\OnCloseInterface;
 use Server\SInterface\OnConnectInterface;
 use Server\SInterface\OnRequestInterface;
+use Swoole\Coroutine\Iterator;
 use Swoole\Http\Request;
 use Swoole\Http\Response;
 use Swoole\Server;
@@ -113,7 +115,8 @@ class Http implements OnCloseInterface, OnConnectInterface, OnRequestInterface
 	{
 		$middlewares = MiddlewareManager::get($handler->callback);
 
-		$dispatcher = new Dispatcher($handler, $middlewares);
+
+		$dispatcher = new Dispatcher($handler, new Iterator($middlewares));
 
 		return $dispatcher->handle($PsrRequest);
 	}