From 0bc96eaa93d01111a2571d92d1bcd904141d7cae Mon Sep 17 00:00:00 2001 From: eyal farago Date: Thu, 21 Oct 2021 14:19:52 +0300 Subject: [PATCH] akka_30782__fmp_postSop_nvm: flatMapPrefix: postStop: check promise completion before instantiating the abrupt termination exception (#30798) --- .../main/scala/akka/stream/impl/fusing/FlatMapPrefix.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/akka-stream/src/main/scala/akka/stream/impl/fusing/FlatMapPrefix.scala b/akka-stream/src/main/scala/akka/stream/impl/fusing/FlatMapPrefix.scala index ef993bdad7..23090fbd0b 100644 --- a/akka-stream/src/main/scala/akka/stream/impl/fusing/FlatMapPrefix.scala +++ b/akka-stream/src/main/scala/akka/stream/impl/fusing/FlatMapPrefix.scala @@ -44,7 +44,9 @@ import akka.util.OptionVal override def postStop(): Unit = { //this covers the case when the nested flow was never materialized - matPromise.tryFailure(new AbruptStageTerminationException(this)) + if (!matPromise.isCompleted) { + matPromise.failure(new AbruptStageTerminationException(this)) + } super.postStop() }