(pekko-http) branch main updated: issue with comments failing build (#1149)

[fa...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

pjfanning pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-http.git


The following commit(s) were added to refs/heads/main by this push:
     new d720e9126 issue with comments failing build (#1149)
d720e9126 is described below

commit d720e9126a19c12575105cf30100d6fd2305e044
Author: PJ Fanning <pj...@users.noreply.github.com>
AuthorDate: Fri Jul 10 13:38:36 2026 +0100

    issue with comments failing build (#1149)
---
 .../pekko/http/impl/engine/ws/WSClientAutobahnTest.scala   | 14 +++++---------
 1 file changed, 5 insertions(+), 9 deletions(-)

diff --git a/http-core/src/test/scala/org/apache/pekko/http/impl/engine/ws/WSClientAutobahnTest.scala b/http-core/src/test/scala/org/apache/pekko/http/impl/engine/ws/WSClientAutobahnTest.scala
index 5d002308d..8b5d72523 100644
--- a/http-core/src/test/scala/org/apache/pekko/http/impl/engine/ws/WSClientAutobahnTest.scala
+++ b/http-core/src/test/scala/org/apache/pekko/http/impl/engine/ws/WSClientAutobahnTest.scala
@@ -88,10 +88,7 @@ object WSClientAutobahnTest {
     def updateReports(agent: String = Agent): Future[Unit] =
       runToSingleText(updateReportsUri(agent)).map(_ => ())
 
-    /**
-     * Map from textual case ID (like 1.1.1) to IndexedCaseInfo
-     * @return
-     */
+    // Map from textual case ID (like 1.1.1) to IndexedCaseInfo
     def getCaseMap(): Future[Map[String, IndexedCaseInfo]] = {
       val res =
         getCaseCount().flatMap { count =>
@@ -176,11 +173,9 @@ object WSClientAutobahnTest {
     def completionSignal[T]: Flow[T, T, Future[Done]] =
       Flow[T].watchTermination((_, res) => res)
 
-    /**
-     * The autobahn tests define a weird API where every request must be a WebSocket request and
-     * they will send a single websocket message with the result. WebSocket everywhere? Strange,
-     * but somewhat consistent.
-     */
+    // The autobahn tests define a weird API where every request must be a WebSocket request and
+    // they will send a single websocket message with the result. WebSocket everywhere? Strange,
+    // but somewhat consistent.
     def runToSingleText(uri: Uri): Future[String] = {
       val sink = Sink.head[Message]
       runWs(uri, Flow.fromSinkAndSourceMat(sink, Source.maybe[Message])(Keep.left)).flatMap {
@@ -189,6 +184,7 @@ object WSClientAutobahnTest {
           throw new IllegalStateException(s"unexpected element of type ${other.getClass}")
       }
     }
+
     def runToSingleJsonValue[T: JsonReader](uri: Uri): Future[T] =
       runToSingleText(uri).map(_.parseJson.convertTo[T])
 


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org