From ee995970efbf756f7e137eb2693f24acd15d0f83 Mon Sep 17 00:00:00 2001 From: Arnout Engelen Date: Fri, 6 Aug 2021 09:50:38 +0200 Subject: [PATCH] Fix FlowFlatMapPrefixSpec instability `notUsedF` is resolved immediately when the substream is materialized, unlike `suffixF` which is resolved when the stream completes. For this reason it is entirely possible that `notUsedF` resolves before getting the subscriptions. Fixes #30469 --- .../test/scala/akka/stream/scaladsl/FlowFlatMapPrefixSpec.scala | 1 - 1 file changed, 1 deletion(-) diff --git a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowFlatMapPrefixSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowFlatMapPrefixSpec.scala index cf7bfa9767..006c2e6734 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowFlatMapPrefixSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowFlatMapPrefixSpec.scala @@ -423,7 +423,6 @@ class FlowFlatMapPrefixSpec extends StreamSpec("akka.loglevel = debug") { .withAttributes(attributes) .run() - notUsedF.value should be(empty) suffixF.value should be(empty) srcWatchTermF.value should be(empty)