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

Fix typos of OutgoingConnectionStage's port names.

Browse source
This commit is contained in:
zhongl 2019-03-01 15:22:51 +08:00
parent ef8414d253
commit 1c5c7be8ea
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-stream/src/main/scala/akka/stream/impl/io/TcpStages.scala
View file

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