From ea76a0c4d33d62749ff99f39f7bd8e95e79d4a13 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Johan=20Andr=C3=A9n?= Date: Tue, 14 Nov 2017 11:51:02 +0100 Subject: [PATCH] One more tryFailure --- akka-stream/src/main/scala/akka/stream/impl/io/TcpStages.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 afdb151981..9e621f8da5 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 @@ -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))