Rearrange

src/Connection/Internal/Http2ConnectionProcessor.php

@@ -1075,6 +1075,8 @@ public function isClosed(): bool
 
     private function runReadFiber(): void
     {
+        $parser = new Http2Parser($this, $this->hpack);
+
         try {
             $this->frameQueue->push(Http2Parser::PREFACE);
 
@@ -1092,19 +1094,7 @@ private function runReadFiber(): void
                     self::DEFAULT_MAX_FRAME_SIZE
                 )
             )->await();
-        } catch (\Throwable $exception) {
-            $this->shutdown(new SocketException(
-                "The HTTP/2 connection closed" . ($this->shutdown !== null ? ' unexpectedly' : ''),
-                $this->shutdown ?? Http2Parser::GRACEFUL_SHUTDOWN,
-                $exception,
-            ), 0);
-
-            return;
-        }
 
-        $parser = new Http2Parser($this, $this->hpack);
-
-        try {
             while (null !== $chunk = $this->socket->read()) {
                 $parser->push($chunk);
             }
@@ -1115,8 +1105,6 @@ private function runReadFiber(): void
                 Http2Parser::INTERNAL_ERROR,
                 $exception,
             ));
-
-            return;
         } finally {
             $parser->cancel();
 
@@ -1132,9 +1120,9 @@ private function runReadFiber(): void
             }
 
             $this->frameQueue->complete();
-        }
 
-        $this->shutdown();
+            $this->shutdown();
+        }
     }
 
     private function writeFrame(

test/Connection/Http2ConnectionTest.php

@@ -569,6 +569,8 @@ public function testServerGoAwayFrame(): void
 
             $this->server->write(self::packFrame('test', Http2Parser::DATA, Http2Parser::END_STREAM, 1));
 
+            delay(0.1);
+
             $this->server->close();
         });