From 78ffa91c4a0ebeac90dec14cf7b7ce63e9974372 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Johan=20Andr=C3=A9n?= Date: Mon, 30 Nov 2020 11:42:03 +0100 Subject: [PATCH] Fix for stream ref test fail #29843 (#29845) --- .../src/test/scala/akka/stream/scaladsl/StreamRefsSpec.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/StreamRefsSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/StreamRefsSpec.scala index 003f487a4a..94747d2eeb 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/StreamRefsSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/StreamRefsSpec.scala @@ -419,7 +419,9 @@ class StreamRefsSpec extends AkkaSpec(StreamRefsSpec.config()) { // "concurrently" ks.shutdown() - remoteControl.success(None) + // note that while unlikely the killswitch shutdown can already have reached the source.maybe and in that case the + // remoteControl is already completed here + remoteControl.trySuccess(None) // since it is a race we can only confirm that it either completes or fails both sides // if it didn't work