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") }