=str #17008 Close the TcpConnectionStream on failure.

2015-03-12 15:15:37 +00:00 · 2015-03-12 15:15:37 +00:00 · ee298a13c0
commit ee298a13c0
parent c383ce46e2
1 changed files with 1 additions and 0 deletions
--- a/akka-stream/src/main/scala/akka/stream/impl/io/TcpConnectionStream.scala
+++ b/akka-stream/src/main/scala/akka/stream/impl/io/TcpConnectionStream.scala
@ -224,6 +224,7 @@ private[akka] abstract class TcpStreamActor(val settings: ActorFlowMaterializerS
    tcpOutputs.error(e)
    primaryInputs.cancel()
    primaryOutputs.error(e)
+    tryShutdown()
  }

  def tryShutdown(): Unit =