From d793ffb5dcad974312c8d4d1da0e5ac93ed0bb22 Mon Sep 17 00:00:00 2001 From: WangYifu Date: Thu, 9 Nov 2017 18:01:12 +0800 Subject: [PATCH] fix the name of SinkModulePhase (#23939) --- .../scala/akka/stream/impl/PhasedFusingActorMaterializer.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/akka-stream/src/main/scala/akka/stream/impl/PhasedFusingActorMaterializer.scala b/akka-stream/src/main/scala/akka/stream/impl/PhasedFusingActorMaterializer.scala index 9bf752929b..c3ef66cbf0 100644 --- a/akka-stream/src/main/scala/akka/stream/impl/PhasedFusingActorMaterializer.scala +++ b/akka-stream/src/main/scala/akka/stream/impl/PhasedFusingActorMaterializer.scala @@ -801,7 +801,7 @@ private final case class SavedIslandData(islandGlobalOffset: Int, lastVisitedOff */ @InternalApi private[akka] final class SinkModulePhase(materializer: PhasedFusingActorMaterializer, islandName: String) extends PhaseIsland[AnyRef] { - override def name: String = s"SourceModule phase" + override def name: String = s"SinkModule phase" var subscriberOrVirtualPublisher: AnyRef = _ override def materializeAtomic(mod: AtomicModule[Shape, Any], attributes: Attributes): (AnyRef, Any) = {