You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by jr...@apache.org on 2022/11/03 11:24:10 UTC
[incubator-pekko-http] 40/47: core: use Tcp(system) consistently
This is an automated email from the ASF dual-hosted git repository.
jrudolph pushed a commit to branch scala-3
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-http.git
commit 0af0c322d17b2fca6ff1841c5b75c2388228f5fd
Author: Johannes Rudolph <jo...@gmail.com>
AuthorDate: Thu May 5 15:58:03 2022 +0200
core: use Tcp(system) consistently
---
.../test/scala/akka/http/impl/engine/client/ConnectionPoolSpec.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/akka-http-core/src/test/scala/akka/http/impl/engine/client/ConnectionPoolSpec.scala b/akka-http-core/src/test/scala/akka/http/impl/engine/client/ConnectionPoolSpec.scala
index c8d0b0c9b..7c5552cde 100644
--- a/akka-http-core/src/test/scala/akka/http/impl/engine/client/ConnectionPoolSpec.scala
+++ b/akka-http-core/src/test/scala/akka/http/impl/engine/client/ConnectionPoolSpec.scala
@@ -666,7 +666,7 @@ class NewConnectionPoolSpec extends AkkaSpecWithMaterializer("""
val sink = if (autoAccept) Sink.foreach[Http.IncomingConnection](handleConnection) else Sink.fromSubscriber(incomingConnections)
val binding =
- Tcp.apply
+ Tcp(system)
.bind("localhost", 0, idleTimeout = serverSettings.timeouts.idleTimeout)
.map { c =>
val layer = Http().serverLayer(serverSettings, log = log)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org