Try fail in case the unbind promise was already completed

This commit is contained in:
Johan Andrén 2017-11-14 11:32:48 +01:00
parent 7bdd6c8934
commit bdfcbc28da

View file

@ -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)
}
}