You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by he...@apache.org on 2024/12/22 12:43:59 UTC
(pekko) branch main updated: chore: fix some IDEA hints. (#1617)
This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko.git
The following commit(s) were added to refs/heads/main by this push:
new 65fc751265 chore: fix some IDEA hints. (#1617)
65fc751265 is described below
commit 65fc75126595d668a96719d5e3670c69495630bb
Author: He-Pin(kerr) <he...@gmail.com>
AuthorDate: Sun Dec 22 20:43:53 2024 +0800
chore: fix some IDEA hints. (#1617)
---
.../pekko/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 81bd562bc3..2e70ce0d00 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)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org