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 431842af4d..72022d8485 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 @@ -145,12 +145,13 @@ class StreamTestKitSpec extends AkkaSpec { "#expectNextWithTimeoutPF 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) .expectNextWithTimeoutPF(timeout, { case 1 ⇒ }) + }.getMessage should include("timeout") }