From 503811f634d3c51a01f5a7a138558b807dd40052 Mon Sep 17 00:00:00 2001 From: Christopher Batey Date: Mon, 16 Jul 2018 06:21:54 +0100 Subject: [PATCH] Harden StreamTestKitSpec Closes #24956 --- .../src/test/scala/akka/stream/testkit/StreamTestKitSpec.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/akka-stream-testkit/src/test/scala/akka/stream/testkit/StreamTestKitSpec.scala b/akka-stream-testkit/src/test/scala/akka/stream/testkit/StreamTestKitSpec.scala index 72022d8485..20542eac70 100644 --- a/akka-stream-testkit/src/test/scala/akka/stream/testkit/StreamTestKitSpec.scala +++ b/akka-stream-testkit/src/test/scala/akka/stream/testkit/StreamTestKitSpec.scala @@ -184,11 +184,12 @@ class StreamTestKitSpec extends AkkaSpec { "#expectNextChainingPF should fail after timeout when element delayed" in { intercept[AssertionError] { val timeout = 100.millis - val overTimeout = timeout + (10.millis) + val overTimeout = timeout + 50.millis Source.tick(overTimeout, 1.millis, 1).runWith(TestSink.probe) .request(1) .expectNextChainingPF(timeout, { case 1 ⇒ + system.log.info("Message received :(") }) }.getMessage should include("timeout") }