From e5c0872603f6d33eb0973d6c8093a7928bcc07e1 Mon Sep 17 00:00:00 2001 From: 2beaucoup Date: Fri, 6 May 2016 23:58:01 +0200 Subject: [PATCH] =str remove unused akka.stream.impl.fusing.Completed (#20468) --- .../scala/akka/stream/impl/fusing/Ops.scala | 22 ------------------- 1 file changed, 22 deletions(-) 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 */