From 1c5c7be8ea7ad9eb9efab2459be02f741eb5fe0e Mon Sep 17 00:00:00 2001 From: zhongl Date: Fri, 1 Mar 2019 15:22:51 +0800 Subject: [PATCH] Fix typos of OutgoingConnectionStage's port names. --- .../src/main/scala/akka/stream/impl/io/TcpStages.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/akka-stream/src/main/scala/akka/stream/impl/io/TcpStages.scala b/akka-stream/src/main/scala/akka/stream/impl/io/TcpStages.scala index 157562ccb3..1a8dcb7e00 100644 --- a/akka-stream/src/main/scala/akka/stream/impl/io/TcpStages.scala +++ b/akka-stream/src/main/scala/akka/stream/impl/io/TcpStages.scala @@ -409,8 +409,8 @@ private[stream] object ConnectionSourceStage { extends GraphStageWithMaterializedValue[FlowShape[ByteString, ByteString], Future[StreamTcp.OutgoingConnection]] { import TcpConnectionStage._ - val bytesIn: Inlet[ByteString] = Inlet("IncomingTCP.in") - val bytesOut: Outlet[ByteString] = Outlet("IncomingTCP.out") + val bytesIn: Inlet[ByteString] = Inlet("OutgoingTCP.in") + val bytesOut: Outlet[ByteString] = Outlet("OutgoingTCP.out") override def initialAttributes = Attributes.name("OutgoingConnection") val shape: FlowShape[ByteString, ByteString] = FlowShape(bytesIn, bytesOut)