raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

=str remove unused akka.stream.impl.fusing.Completed (#20468)

Browse source
This commit is contained in:
2beaucoup 2016-05-06 23:58:01 +02:00 • committed by Konrad Malawski
parent e8937f967a
commit e5c0872603
1 changed files with 0 additions and 22 deletions
Download patch file Download diff file Expand all files Collapse all files

22
akka-stream/src/main/scala/akka/stream/impl/fusing/Ops.scala
View file

@ -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
*/