From 6021e00a15776403eb7e7704f956a484208e6ca5 Mon Sep 17 00:00:00 2001 From: Schmitt Christian Date: Wed, 17 Aug 2016 09:39:31 +0200 Subject: [PATCH] removes a blocking InetSocketAddress call with createUnresolved #21149 --- akka-stream/src/main/scala/akka/stream/scaladsl/Tcp.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/akka-stream/src/main/scala/akka/stream/scaladsl/Tcp.scala b/akka-stream/src/main/scala/akka/stream/scaladsl/Tcp.scala index bdcbf0ad99..43e2dd2b2e 100644 --- a/akka-stream/src/main/scala/akka/stream/scaladsl/Tcp.scala +++ b/akka-stream/src/main/scala/akka/stream/scaladsl/Tcp.scala @@ -183,5 +183,5 @@ final class Tcp(system: ExtendedActorSystem) extends akka.actor.Extension { * It represents a prospective TCP client connection to the given endpoint. */ def outgoingConnection(host: String, port: Int): Flow[ByteString, ByteString, Future[OutgoingConnection]] = - outgoingConnection(new InetSocketAddress(host, port)) + outgoingConnection(InetSocketAddress.createUnresolved(host, port)) }