You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by fa...@apache.org on 2025/09/03 18:44:55 UTC
(pekko-http) branch main updated: avoid deprecated method used in test code (#742)
This is an automated email from the ASF dual-hosted git repository.
fanningpj 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 869e784fd avoid deprecated method used in test code (#742)
869e784fd is described below
commit 869e784fd9f6386ebf15f326f78ea435e3b6b84c
Author: PJ Fanning <pj...@users.noreply.github.com>
AuthorDate: Wed Sep 3 19:44:49 2025 +0100
avoid deprecated method used in test code (#742)
---
.../org/apache/pekko/http/impl/engine/http2/TelemetrySpiSpec.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/http2-tests/src/test/scala/org/apache/pekko/http/impl/engine/http2/TelemetrySpiSpec.scala b/http2-tests/src/test/scala/org/apache/pekko/http/impl/engine/http2/TelemetrySpiSpec.scala
index 338fe3293..e78f36a7c 100644
--- a/http2-tests/src/test/scala/org/apache/pekko/http/impl/engine/http2/TelemetrySpiSpec.scala
+++ b/http2-tests/src/test/scala/org/apache/pekko/http/impl/engine/http2/TelemetrySpiSpec.scala
@@ -150,7 +150,7 @@ abstract class TelemetrySpiSpec(useTls: Boolean) extends PekkoSpecWithMaterializ
val (requestQueue, _) =
Source.queue(10, OverflowStrategy.fail)
.viaMat(http2ClientFow)(Keep.left)
- .toMat(Sink.actorRef(responseProbe.ref, "done"))(Keep.both)
+ .toMat(Sink.actorRef(responseProbe.ref, "done", (t: Throwable) => t.toString))(Keep.both)
.run()
requestQueue.offer(HttpRequest())
@@ -217,7 +217,7 @@ abstract class TelemetrySpiSpec(useTls: Boolean) extends PekkoSpecWithMaterializ
val (requestQueue, _) =
Source.queue(10, OverflowStrategy.fail)
.viaMat(http2ClientFlow)(Keep.left)
- .toMat(Sink.actorRef(responseProbe.ref, "onCompleteMessage"))(Keep.both)
+ .toMat(Sink.actorRef(responseProbe.ref, "onCompleteMessage", (t: Throwable) => t.toString))(Keep.both)
.run()
requestQueue.offer(HttpRequest())
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org