From 2fd9bb736baddc73a90e48ad59d7f8372a83ed20 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Martynas=20Mickevi=C4=8Dius?= Date: Wed, 6 Dec 2017 20:52:47 +0700 Subject: [PATCH] #24097 Try a few times to get an exception --- .../test/scala/akka/stream/io/OutputStreamSourceSpec.scala | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/akka-stream-tests/src/test/scala/akka/stream/io/OutputStreamSourceSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/io/OutputStreamSourceSpec.scala index 04bd25fe0d..76b1994392 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/io/OutputStreamSourceSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/io/OutputStreamSourceSpec.scala @@ -160,7 +160,10 @@ class OutputStreamSourceSpec extends StreamSpec(UnboundedMailboxConfig) { s.cancel() sourceProbe.expectMsg(GraphStageMessages.DownstreamFinish) - the[Exception] thrownBy outputStream.write(bytesArray) shouldBe a[IOException] + + awaitAssert { + the[Exception] thrownBy outputStream.write(bytesArray) shouldBe a[IOException] + } } "fail to materialize with zero sized input buffer" in {