diff --git a/akka-docs-dev/rst/scala/code/docs/stream/FlowGraphDocSpec.scala b/akka-docs-dev/rst/scala/code/docs/stream/FlowGraphDocSpec.scala
index be79d14995..1a8d52f21c 100644
--- a/akka-docs-dev/rst/scala/code/docs/stream/FlowGraphDocSpec.scala
+++ b/akka-docs-dev/rst/scala/code/docs/stream/FlowGraphDocSpec.scala
@@ -149,7 +149,7 @@ class FlowGraphDocSpec extends AkkaSpec {
     //#flow-graph-components-create
     object PriorityWorkerPool {
       def apply[In, Out](
-        worker: Flow[In, Out, _],
+        worker: Flow[In, Out, Any],
         workerCount: Int): Graph[PriorityWorkerPoolShape[In, Out], Unit] = {
 
         FlowGraph.partial() { implicit b ⇒
diff --git a/akka-docs-dev/rst/scala/code/docs/stream/IntegrationDocSpec.scala b/akka-docs-dev/rst/scala/code/docs/stream/IntegrationDocSpec.scala
index d991d52d8e..d0657cee1c 100644
--- a/akka-docs-dev/rst/scala/code/docs/stream/IntegrationDocSpec.scala
+++ b/akka-docs-dev/rst/scala/code/docs/stream/IntegrationDocSpec.scala
@@ -5,12 +5,9 @@ package docs.stream
 
 import scala.concurrent.duration._
 import akka.stream.testkit.AkkaSpec
-import akka.stream.scaladsl.Source
-import java.util.Date
+import akka.stream.scaladsl._
 import akka.stream.ActorFlowMaterializer
 import scala.concurrent.Future
-import akka.stream.scaladsl.RunnableFlow
-import akka.stream.scaladsl.Sink
 import akka.testkit.TestProbe
 import akka.actor.ActorRef
 import com.typesafe.config.ConfigFactory
@@ -18,7 +15,6 @@ import akka.actor.Actor
 import akka.actor.Props
 import akka.pattern.ask
 import akka.util.Timeout
-import akka.stream.scaladsl.OperationAttributes
 import scala.concurrent.ExecutionContext
 import akka.stream.ActorFlowMaterializerSettings
 import java.util.concurrent.atomic.AtomicInteger
diff --git a/akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeWorkerPool.scala b/akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeWorkerPool.scala
index b547efa5ac..529e1ddb4b 100644
--- a/akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeWorkerPool.scala
+++ b/akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeWorkerPool.scala
@@ -17,7 +17,7 @@ class RecipeWorkerPool extends RecipeSpec {
       val worker = Flow[String].map(_ + " done")
 
       //#worker-pool
-      def balancer[In, Out](worker: Flow[In, Out, Unit], workerCount: Int): Flow[In, Out, Unit] = {
+      def balancer[In, Out](worker: Flow[In, Out, Any], workerCount: Int): Flow[In, Out, Unit] = {
         import FlowGraph.Implicits._
 
         Flow() { implicit b =>