[NOT FOR MERGE] test with 1.1.0-M1-RC1

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

@@ -40,19 +40,34 @@
       if (byteStringInputStreamMethodTypeOpt.isDefined) {
         byteStringInputStreamMethodTypeOpt.get.invoke(bs).asInstanceOf[InputStream]
       } else {
-        legacyConvert(bs.compact)
+        asByteArrayInputStream(bs.compact)
       }
   }
 
-  private def legacyConvert(bs: ByteString): InputStream = bs match {
+  def asByteArrayInputStream(bs: ByteString): ByteArrayInputStream = bs match {
     case cs: ByteString1C =>
       getInputStreamUnsafe(cs)
     case _ =>
       // NOTE: We actually measured recently, and compact + use array was pretty good usually
-      legacyConvert(bs.compact)
+      getInputStreamUnsafe(bs.compact)
   }
 
-  private def getInputStreamUnsafe(bs: ByteString): InputStream =
+  private def getInputStreamUnsafe(bs: ByteString): ByteArrayInputStream =
     new ByteArrayInputStream(bs.toArrayUnsafe())
 
+  private def asString(stream: InputStream): String = {
+    val bos = new java.io.ByteArrayOutputStream()
+    val array = new Array[Byte](4096)
+    try {
+      var n = stream.read(array)
+      while (n != -1) {
+        bos.write(array, 0, n)
+        n = stream.read(array)
+      }
+      bos.toString("UTF-8")
+    } finally {
+      bos.close()
+    }
+  }
+
 }

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

@@ -93,7 +93,7 @@ private[http2] final class HeaderDecompression(masterHeaderParser: HttpHeaderPar
           }
         }
         try {
-          decoder.decode(ByteStringInputStream(payload), Receiver)
+          decoder.decode(ByteStringInputStream.asByteArrayInputStream(payload), Receiver)
           decoder.endHeaderBlock() // TODO: do we have to check the result here?
 
           push(eventsOut, ParsedHeadersFrame(streamId, endStream, headers.result(), prioInfo))