#18151: Fail Futures returned by TCP when connection fails

2015-08-09 16:25:35 -04:00 · 2015-08-09 16:25:35 -04:00 · c6ce2dbb3d
commit c6ce2dbb3d
parent 3573d120de
1 changed files with 6 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
@ -335,4 +335,10 @@ private[akka] class OutboundTcpStreamActor(processorPromise: Promise[Processor[B
      processorPromise.failure(ex)
      fail(ex)
  }
+
+  override def fail(e: Throwable): Unit = {
+    processorPromise.tryFailure(e)
+    localAddressPromise.tryFailure(e)
+    super.fail(e)
+  }
 }