raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

removes a blocking InetSocketAddress call with createUnresolved #21149

Browse source
This commit is contained in:
Schmitt Christian 2016-08-17 09:39:31 +02:00 • committed by Johan Andrén
parent 90aba99340
commit 6021e00a15
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-stream/src/main/scala/akka/stream/scaladsl/Tcp.scala
View file

@ -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))
}