chore: avoid create an empty array everytime.

apache · Dec 22, 2024 · dcef05b · dcef05b
1 parent 8bb6e22
commit dcef05b
Showing 1 changed file with 10 additions and 3 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
@@ -686,6 +686,15 @@ private final case class SavedIslandData(
  */
 @InternalApi private[pekko] object GraphStageTag extends IslandTag
 
+/**
+ * INTERNAL API
+ */
+@InternalApi
+private[pekko] object GraphStageIsland {
+  // used as a type hint when creating the array of logics
+  private final val emptyLogicArray = Array.empty[GraphStageLogic]
+}
+
 /**
  * INTERNAL API
  */
@@ -695,8 +704,6 @@ private final case class SavedIslandData(
     islandName: String,
     subflowFuser: OptionVal[GraphInterpreterShell => ActorRef])
     extends PhaseIsland[GraphStageLogic] {
-  // TODO: remove these
-  private val logicArrayType = Array.empty[GraphStageLogic]
   private[this] val logics = new util.ArrayList[GraphStageLogic](16)
 
   private var connections = new Array[Connection](16)
@@ -815,7 +822,7 @@ private final case class SavedIslandData(
     }
 
     shell.connections = finalConnections
-    shell.logics = logics.toArray(logicArrayType)
+    shell.logics = logics.toArray(GraphStageIsland.emptyLogicArray)
 
     subflowFuser match {
       case OptionVal.Some(fuseIntoExistingInterpreter) =>