From f88ee384c306041ce6a7c2457c37c583dc40b35a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Johan=20Andr=C3=A9n?= Date: Fri, 6 Sep 2019 09:11:57 +0200 Subject: [PATCH] watchTermination now fails the future on downstream failure #27640 --- .../test/scala/docs/stream/cookbook/RecipeAdhocSource.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/akka-docs/src/test/scala/docs/stream/cookbook/RecipeAdhocSource.scala b/akka-docs/src/test/scala/docs/stream/cookbook/RecipeAdhocSource.scala index 8a97df08b4..d51407340a 100644 --- a/akka-docs/src/test/scala/docs/stream/cookbook/RecipeAdhocSource.scala +++ b/akka-docs/src/test/scala/docs/stream/cookbook/RecipeAdhocSource.scala @@ -50,7 +50,7 @@ class RecipeAdhocSource extends RecipeSpec { sink.requestNext("a") Thread.sleep(200) - shutdown.future.futureValue should be(Done) + shutdown.future.failed.futureValue shouldBe a[TimeoutException] } "not shut down the source when there are still demands" taggedAs TimingTest in { @@ -86,7 +86,7 @@ class RecipeAdhocSource extends RecipeSpec { sink.requestNext("a") startedCount.get() should be(1) Thread.sleep(200) - shutdown.future.futureValue should be(Done) + shutdown.future.failed.futureValue shouldBe a[TimeoutException] } "restart up to specified maxRetries" taggedAs TimingTest in {