Package akka.stream.impl
Class GraphStageIsland
- java.lang.Object
-
- akka.stream.impl.GraphStageIsland
-
- All Implemented Interfaces:
PhaseIsland<GraphStageLogic>
public final class GraphStageIsland extends java.lang.Object implements PhaseIsland<GraphStageLogic>
INTERNAL API
-
-
Constructor Summary
Constructors Constructor Description GraphStageIsland(ActorMaterializerSettings settings, Attributes effectiveAttributes, PhasedFusingActorMaterializer materializer, java.lang.String islandName, OptionVal<scala.Function1<GraphInterpreterShell,ActorRef>> subflowFuser)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
assignPort(InPort in, int slot, GraphStageLogic logic)
void
assignPort(OutPort out, int slot, GraphStageLogic logic)
GraphInterpreter.Connection
conn(int slot)
org.reactivestreams.Publisher<java.lang.Object>
createPublisher(OutPort out, GraphStageLogic logic)
scala.Tuple2<GraphStageLogic,java.lang.Object>
materializeAtomic(StreamLayout.AtomicModule<Shape,java.lang.Object> mod, Attributes attributes)
java.lang.String
name()
void
onIslandReady()
GraphInterpreter.Connection
outConn()
GraphInterpreterShell
shell()
void
takePublisher(int slot, org.reactivestreams.Publisher<java.lang.Object> publisher)
java.lang.String
toString()
-
-
-
Constructor Detail
-
GraphStageIsland
public GraphStageIsland(ActorMaterializerSettings settings, Attributes effectiveAttributes, PhasedFusingActorMaterializer materializer, java.lang.String islandName, OptionVal<scala.Function1<GraphInterpreterShell,ActorRef>> subflowFuser)
-
-
Method Detail
-
assignPort
public void assignPort(InPort in, int slot, GraphStageLogic logic)
- Specified by:
assignPort
in interfacePhaseIsland<GraphStageLogic>
-
assignPort
public void assignPort(OutPort out, int slot, GraphStageLogic logic)
- Specified by:
assignPort
in interfacePhaseIsland<GraphStageLogic>
-
conn
public GraphInterpreter.Connection conn(int slot)
-
createPublisher
public org.reactivestreams.Publisher<java.lang.Object> createPublisher(OutPort out, GraphStageLogic logic)
- Specified by:
createPublisher
in interfacePhaseIsland<GraphStageLogic>
-
materializeAtomic
public scala.Tuple2<GraphStageLogic,java.lang.Object> materializeAtomic(StreamLayout.AtomicModule<Shape,java.lang.Object> mod, Attributes attributes)
- Specified by:
materializeAtomic
in interfacePhaseIsland<GraphStageLogic>
-
name
public java.lang.String name()
- Specified by:
name
in interfacePhaseIsland<GraphStageLogic>
-
onIslandReady
public void onIslandReady()
- Specified by:
onIslandReady
in interfacePhaseIsland<GraphStageLogic>
-
outConn
public GraphInterpreter.Connection outConn()
-
shell
public GraphInterpreterShell shell()
-
takePublisher
public void takePublisher(int slot, org.reactivestreams.Publisher<java.lang.Object> publisher)
- Specified by:
takePublisher
in interfacePhaseIsland<GraphStageLogic>
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-