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

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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()

phases

public scala.collection.immutable.Map<IslandTag,Phase<java.lang.Object>> phases()

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)