From 65fc75126595d668a96719d5e3670c69495630bb Mon Sep 17 00:00:00 2001 From: "He-Pin(kerr)" Date: Sun, 22 Dec 2024 20:43:53 +0800 Subject: [PATCH] chore: fix some IDEA hints. (#1617) --- .../stream/impl/PhasedFusingActorMaterializer.scala | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/stream/src/main/scala/org/apache/pekko/stream/impl/PhasedFusingActorMaterializer.scala b/stream/src/main/scala/org/apache/pekko/stream/impl/PhasedFusingActorMaterializer.scala index 81bd562bc3a..2e70ce0d002 100644 --- a/stream/src/main/scala/org/apache/pekko/stream/impl/PhasedFusingActorMaterializer.scala +++ b/stream/src/main/scala/org/apache/pekko/stream/impl/PhasedFusingActorMaterializer.scala @@ -869,7 +869,7 @@ private final case class SavedIslandData( materializer: PhasedFusingActorMaterializer, islandName: String) extends PhaseIsland[Publisher[Any]] { - override def name: String = s"SourceModule phase" + override def name: String = "SourceModule phase" override def materializeAtomic(mod: AtomicModule[Shape, Any], attributes: Attributes): (Publisher[Any], Any) = { mod @@ -899,8 +899,8 @@ private final case class SavedIslandData( */ @InternalApi private[pekko] final class SinkModulePhase(materializer: PhasedFusingActorMaterializer, islandName: String) extends PhaseIsland[AnyRef] { - override def name: String = s"SinkModule phase" - var subscriberOrVirtualPublisher: AnyRef = _ + override def name: String = "SinkModule phase" + private var subscriberOrVirtualPublisher: AnyRef = _ override def materializeAtomic(mod: AtomicModule[Shape, Any], attributes: Attributes): (AnyRef, Any) = { val subAndMat = @@ -971,7 +971,7 @@ private final case class SavedIslandData( extends PhaseIsland[NotUsed] { def name: String = "TlsModulePhase" - var tlsActor: ActorRef = _ + private var tlsActor: ActorRef = _ var publishers: Vector[ActorPublisher[Any]] = _ def materializeAtomic(mod: AtomicModule[Shape, Any], attributes: Attributes): (NotUsed, Any) = { @@ -987,7 +987,7 @@ private final case class SavedIslandData( tlsActor = materializer.actorOf(props, "TLS-for-" + islandName) def factory(id: Int) = new ActorPublisher[Any](tlsActor) { - override val wakeUpMsg = FanOut.SubstreamSubscribePending(id) + override val wakeUpMsg: FanOut.SubstreamSubscribePending = FanOut.SubstreamSubscribePending(id) } publishers = Vector.tabulate(2)(factory) tlsActor ! FanOut.ExposedPublishers(publishers)