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

=str Change Detacher to an object. (#31287)

Browse source
This commit is contained in:
kerr 2022-04-02 00:44:57 +08:00 • committed by GitHub
parent 305220459b
commit 7bfd118c71
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-stream/src/main/mima-filters/2.6.19.backwards.excludes/detacher.excludes Normal file
View file

@ -0,0 +1,2 @@
#Change Detacher from class to object.
ProblemFilters.exclude[MissingClassProblem]("akka.stream.impl.fusing.GraphStages$Detacher")

5
akka-stream/src/main/scala/akka/stream/impl/fusing/GraphStages.scala
View file

@ -77,7 +77,7 @@ import akka.stream.stage._
/** /**
* INTERNAL API * INTERNAL API
*/ */
@InternalApi private[akka] final class Detacher[T] extends SimpleLinearGraphStage[T] { @InternalApi private[akka] object Detacher extends SimpleLinearGraphStage[Any] {
override def initialAttributes = DefaultAttributes.detacher override def initialAttributes = DefaultAttributes.detacher
override def createLogic(inheritedAttributes: Attributes): GraphStageLogic = override def createLogic(inheritedAttributes: Attributes): GraphStageLogic =
@ -114,8 +114,7 @@ import akka.stream.stage._
override def toString = "Detacher" override def toString = "Detacher"
} }
private val _detacher = new Detacher[Any] def detacher[T]: GraphStage[FlowShape[T, T]] = Detacher.asInstanceOf[SimpleLinearGraphStage[T]]
def detacher[T]: GraphStage[FlowShape[T, T]] = _detacher.asInstanceOf[GraphStage[FlowShape[T, T]]]
private object TerminationWatcher extends GraphStageWithMaterializedValue[FlowShape[Any, Any], Future[Done]] { private object TerminationWatcher extends GraphStageWithMaterializedValue[FlowShape[Any, Any], Future[Done]] {
val in = Inlet[Any]("terminationWatcher.in") val in = Inlet[Any]("terminationWatcher.in")