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

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

Methods inherited from class java.lang.Object

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

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 interface PhaseIsland<GraphStageLogic>

assignPort

public void assignPort(OutPort out,
                       int slot,
                       GraphStageLogic logic)

Specified by:

assignPort in interface PhaseIsland<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 interface PhaseIsland<GraphStageLogic>

materializeAtomic

public scala.Tuple2<GraphStageLogic,java.lang.Object> materializeAtomic(StreamLayout.AtomicModule<Shape,java.lang.Object> mod,
                                                                              Attributes attributes)

Specified by:

materializeAtomic in interface PhaseIsland<GraphStageLogic>

name

public java.lang.String name()

Specified by:

name in interface PhaseIsland<GraphStageLogic>

onIslandReady

public void onIslandReady()

Specified by:

onIslandReady in interface PhaseIsland<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 interface PhaseIsland<GraphStageLogic>

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object