One more tryFailure

2017-11-14 11:51:02 +01:00 · 2017-11-14 11:51:02 +01:00 · ea76a0c4d3
commit ea76a0c4d3
parent acdabeff74
1 changed files with 1 additions and 1 deletions
--- a/akka-stream/src/main/scala/akka/stream/impl/io/TcpStages.scala
+++ b/akka-stream/src/main/scala/akka/stream/impl/io/TcpStages.scala
@ -84,7 +84,7 @@ import scala.concurrent.{ Future, Promise }
            }
            f.cause.foreach(ex.initCause)
            bindingPromise.failure(ex)
-            unbindPromise.failure(ex)
+            unbindPromise.tryFailure(ex)
            failStage(ex)
          case c: Connected ⇒
            push(out, connectionFor(c, sender))