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