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 5c001bf9ef..afdb151981 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 @@ -98,7 +98,7 @@ import scala.concurrent.{ Future, Promise } } else { val ex = new IllegalStateException("IO Listener actor terminated unexpectedly for remote endpoint [" + endpoint.getHostString + ":" + endpoint.getPort + "]") - unbindPromise.failure(ex) + unbindPromise.tryFailure(ex) failStage(ex) } }