raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

watchTermination now fails the future on downstream failure #27640

Browse source
This commit is contained in:
Johan Andrén 2019-09-06 09:11:57 +02:00
parent ed955e0da4
commit f88ee384c3
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-docs/src/test/scala/docs/stream/cookbook/RecipeAdhocSource.scala
View file

@ -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 {