diff --git a/akka-stream-testkit/src/main/scala/akka/stream/testkit/StreamTestKit.scala b/akka-stream-testkit/src/main/scala/akka/stream/testkit/StreamTestKit.scala
index 18133d2714..67cc08575b 100644
--- a/akka-stream-testkit/src/main/scala/akka/stream/testkit/StreamTestKit.scala
+++ b/akka-stream-testkit/src/main/scala/akka/stream/testkit/StreamTestKit.scala
@@ -213,7 +213,7 @@ object TestSubscriber {
      * Expect and return [[SubscriberEvent]] (any of: `OnSubscribe`, `OnNext`, `OnError` or `OnComplete`).
      */
     def expectEvent(max: FiniteDuration): SubscriberEvent =
-      probe.expectMsgType[SubscriberEvent](max.dilated)
+      probe.expectMsgType[SubscriberEvent](max)
 
     /**
      * Fluent DSL