workaround

Author: pjfanning

http-core/src/main/scala/org/apache/pekko/http/impl/engine/http2/Http2Demux.scala

@@ -59,11 +59,12 @@ private[http2] class Http2ClientDemux(http2Settings: Http2ClientSettings, master
     extends Http2Demux(http2Settings, initialRemoteSettings = Nil, upgraded = false, isServer = false) {
 
   def wrapTrailingHeaders(headers: ParsedHeadersFrame): Option[ChunkStreamPart] = {
-    val headerParser = masterHttpHeaderParser.createShallowCopy()
     Some(LastChunk(extension = "",
       headers.keyValuePairs.map {
         case (name, value: HttpHeader) => value
-        case (name, value)             => parseHeaderPair(headerParser, name, value.asInstanceOf[String])
+        case (name, value) =>
+          val headerParser = masterHttpHeaderParser.createShallowCopy()
+          parseHeaderPair(headerParser, name, value.asInstanceOf[String])
       }.toList))
   }
 

http-core/src/main/scala/org/apache/pekko/http/impl/engine/http2/RequestParsing.scala

@@ -191,10 +191,16 @@ private[http2] object RequestParsing {
 
   private[http2] def parseHeaderPair(httpHeaderParser: HttpHeaderParser, name: String, value: String): HttpHeader = {
     import HttpHeader.ParsingResult
-    HttpHeader.parse(name, value, httpHeaderParser.settings) match {
-      case ParsingResult.Ok(header, errors) if errors.isEmpty => header
-      case ParsingResult.Ok(_, errors)                        => throw ParsingException(errors.head)
-      case ParsingResult.Error(info)                          => throw ParsingException(info)
+    if (name.startsWith(":")) {
+      val concHeaderLine = s"$name: $value\r\nx"
+      httpHeaderParser.parseHeaderLine(pekko.util.ByteString(concHeaderLine))()
+      httpHeaderParser.resultHeader
+    } else {
+      HttpHeader.parse(name, value, httpHeaderParser.settings) match {
+        case ParsingResult.Ok(header, errors) if errors.isEmpty => header
+        case ParsingResult.Ok(_, errors)                        => throw ParsingException(errors.head)
+        case ParsingResult.Error(info)                          => throw ParsingException(info)
+      }
     }
   }