Add HttpDriverMergedFactory

src/Driver/HttpDriverMergedFactory.php

@@ -0,0 +1,34 @@
+<?php
+
+namespace Amp\Http\Server\Driver;
+
+use Amp\Http\Server\ErrorHandler;
+use Amp\Http\Server\RequestHandler;
+
+class HttpDriverMergedFactory implements HttpDriverFactory
+{
+    private int $index = 0;
+
+    /**
+     * @param list<HttpDriverMiddleware> $middlewares
+     */
+    public function __construct(private array $middlewares, private HttpDriverFactory $factory)
+    {
+    }
+
+    public function createHttpDriver(RequestHandler $requestHandler, ErrorHandler $errorHandler, Client $client): HttpDriver
+    {
+        if ($this->index >= \count($this->middlewares)) {
+            return $this->factory->createHttpDriver($requestHandler, $errorHandler, $client);
+        }
+
+        $factory = clone $this;
+        ++$factory->index;
+        return $this->middlewares[$this->index]->createHttpDriver($factory, $requestHandler, $errorHandler, $client);
+    }
+
+    public function getApplicationLayerProtocols(): array
+    {
+        return $this->factory->getApplicationLayerProtocols();
+    }
+}

src/Driver/Internal/Http3/Http3Parser.php

@@ -315,12 +315,14 @@ public function process(): ConcurrentIterator
 
                         $type = self::decodeVarintFromStream($stream, $buf, $off);
                         if ($stream->isWritable()) {
-                            // client-initiated bidirectional stream
+                            // bidirectional stream
                             if ($type > 0x0d /* bigger than any default frame */ && $type % 0x1f !== 0x2 /* and not a padding frame */) {
                                 // Unknown frame type. Users may handle it (e.g. WebTransport).
                                 $this->queue->push([$type, \substr($buf, $off), $stream]);
                                 return;
                             }
+
+                            // Note: the parser will also allow for Messages to be sent on new streams. MUST fail connections which do push HEADERS.
                             $off = 0;
                             $messageGenerator = $this->readHttpMessage($stream, $buf, $off);
                             if (!$messageGenerator->valid()) {