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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
