@@ -869,7 +869,7 @@ private final case class SavedIslandData(
869869 materializer: PhasedFusingActorMaterializer,
870870 islandName: String)
871871 extends PhaseIsland[Publisher[Any]] {
872- override def name: String = s "SourceModule phase"
872+ override def name: String = "SourceModule phase"
873873
874874 override def materializeAtomic(mod: AtomicModule[Shape, Any], attributes: Attributes): (Publisher[Any], Any) = {
875875 mod
@@ -899,8 +899,8 @@ private final case class SavedIslandData(
899899 */
900900@InternalApi private[pekko] final class SinkModulePhase(materializer: PhasedFusingActorMaterializer, islandName: String)
901901 extends PhaseIsland[AnyRef] {
902- override def name: String = s "SinkModule phase"
903- var subscriberOrVirtualPublisher: AnyRef = _
902+ override def name: String = "SinkModule phase"
903+ private var subscriberOrVirtualPublisher: AnyRef = _
904904
905905 override def materializeAtomic(mod: AtomicModule[Shape, Any], attributes: Attributes): (AnyRef, Any) = {
906906 val subAndMat =
@@ -971,7 +971,7 @@ private final case class SavedIslandData(
971971 extends PhaseIsland[NotUsed] {
972972 def name: String = "TlsModulePhase"
973973
974- var tlsActor: ActorRef = _
974+ private var tlsActor: ActorRef = _
975975 var publishers: Vector[ActorPublisher[Any]] = _
976976
977977 def materializeAtomic(mod: AtomicModule[Shape, Any], attributes: Attributes): (NotUsed, Any) = {
@@ -987,7 +987,7 @@ private final case class SavedIslandData(
987987
988988 tlsActor = materializer.actorOf(props, "TLS-for-" + islandName)
989989 def factory(id: Int) = new ActorPublisher[Any](tlsActor) {
990- override val wakeUpMsg = FanOut.SubstreamSubscribePending(id)
990+ override val wakeUpMsg: FanOut.SubstreamSubscribePending = FanOut.SubstreamSubscribePending(id)
991991 }
992992 publishers = Vector.tabulate(2)(factory)
993993 tlsActor ! FanOut.ExposedPublishers(publishers)
0 commit comments