Package akka.stream.impl
Class IslandTracking
- java.lang.Object
-
- akka.stream.impl.IslandTracking
-
public class IslandTracking extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description IslandTracking(scala.collection.immutable.Map<IslandTag,Phase<java.lang.Object>> phases, ActorMaterializerSettings settings, Attributes attributes, Phase<java.lang.Object> defaultPhase, PhasedFusingActorMaterializer materializer, java.lang.String islandNamePrefix)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
allNestedIslandsReady()
void
enterIsland(IslandTag tag, Attributes attributes)
void
exitIsland()
int
getCurrentOffset()
PhaseIsland<java.lang.Object>
getCurrentPhase()
PhasedFusingActorMaterializer
materializer()
scala.collection.immutable.Map<IslandTag,Phase<java.lang.Object>>
phases()
ActorMaterializerSettings
settings()
void
wireIn(InPort in, java.lang.Object logic)
void
wireOut(OutPort out, int absoluteOffset, java.lang.Object logic)
-
-
-
Constructor Detail
-
IslandTracking
public IslandTracking(scala.collection.immutable.Map<IslandTag,Phase<java.lang.Object>> phases, ActorMaterializerSettings settings, Attributes attributes, Phase<java.lang.Object> defaultPhase, PhasedFusingActorMaterializer materializer, java.lang.String islandNamePrefix)
-
-
Method Detail
-
allNestedIslandsReady
public void allNestedIslandsReady()
-
enterIsland
public void enterIsland(IslandTag tag, Attributes attributes)
-
exitIsland
public void exitIsland()
-
getCurrentOffset
public int getCurrentOffset()
-
getCurrentPhase
public PhaseIsland<java.lang.Object> getCurrentPhase()
-
materializer
public PhasedFusingActorMaterializer materializer()
-
settings
public ActorMaterializerSettings settings()
-
wireIn
public void wireIn(InPort in, java.lang.Object logic)
-
wireOut
public void wireOut(OutPort out, int absoluteOffset, java.lang.Object logic)
-
-