diff --git a/akka-stream/src/main/scala/akka/stream/impl/fusing/Ops.scala b/akka-stream/src/main/scala/akka/stream/impl/fusing/Ops.scala
index 1a8e449e20..3a9db78910 100644
--- a/akka-stream/src/main/scala/akka/stream/impl/fusing/Ops.scala
+++ b/akka-stream/src/main/scala/akka/stream/impl/fusing/Ops.scala
@@ -565,28 +565,6 @@ private[akka] final case class Buffer[T](size: Int, overflowStrategy: OverflowSt
 
 }
 
-/**
- * INTERNAL API
- */
-private[akka] final case class Completed[T]() extends GraphStage[FlowShape[T, T]] {
-
-  val out: Outlet[T] = Outlet("Completed.out")
-  val in: Inlet[T] = Inlet("Completed.in")
-
-  override def createLogic(inheritedAttributes: Attributes): GraphStageLogic = new GraphStageLogic(shape) with InHandler with OutHandler {
-
-    override def onPush(): Unit = { completeStage() }
-
-    override def onPull(): Unit = { completeStage() }
-
-    setHandlers(in, out, this)
-
-  }
-
-  val shape: FlowShape[T, T] = FlowShape.of(in, out)
-
-}
-
 /**
  * INTERNAL API
  */