diff --git a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowSpec.scala
index bdcebab1df..9adaba3d36 100644
--- a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowSpec.scala
+++ b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowSpec.scala
@@ -16,7 +16,7 @@ import akka.stream.{ AbruptTerminationException, Attributes, ActorMaterializerSe
 import akka.stream.impl._
 import akka.stream.testkit._
 import akka.stream.testkit.Utils._
-import akka.testkit._
+import akka.testkit.{ TestDuration, EventFilter }
 import akka.testkit.TestEvent.{ UnMute, Mute }
 import com.typesafe.config.ConfigFactory
 import org.reactivestreams.{ Subscription, Processor, Subscriber, Publisher }