Package akka.stream.impl
Class SinkModulePhase
- java.lang.Object
-
- akka.stream.impl.SinkModulePhase
-
- All Implemented Interfaces:
PhaseIsland<java.lang.Object>
public final class SinkModulePhase extends java.lang.Object implements PhaseIsland<java.lang.Object>
INTERNAL API
-
-
Constructor Summary
Constructors Constructor Description SinkModulePhase(PhasedFusingActorMaterializer materializer, java.lang.String islandName)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
assignPort(InPort in, int slot, java.lang.Object logic)
void
assignPort(OutPort out, int slot, java.lang.Object logic)
org.reactivestreams.Publisher<java.lang.Object>
createPublisher(OutPort out, java.lang.Object logic)
scala.Tuple2<java.lang.Object,java.lang.Object>
materializeAtomic(StreamLayout.AtomicModule<Shape,java.lang.Object> mod, Attributes attributes)
java.lang.String
name()
void
onIslandReady()
java.lang.Object
subscriberOrVirtualPublisher()
void
subscriberOrVirtualPublisher_$eq(java.lang.Object x$1)
void
takePublisher(int slot, org.reactivestreams.Publisher<java.lang.Object> publisher)
-
-
-
Constructor Detail
-
SinkModulePhase
public SinkModulePhase(PhasedFusingActorMaterializer materializer, java.lang.String islandName)
-
-
Method Detail
-
assignPort
public void assignPort(InPort in, int slot, java.lang.Object logic)
- Specified by:
assignPort
in interfacePhaseIsland<java.lang.Object>
-
assignPort
public void assignPort(OutPort out, int slot, java.lang.Object logic)
- Specified by:
assignPort
in interfacePhaseIsland<java.lang.Object>
-
createPublisher
public org.reactivestreams.Publisher<java.lang.Object> createPublisher(OutPort out, java.lang.Object logic)
- Specified by:
createPublisher
in interfacePhaseIsland<java.lang.Object>
-
materializeAtomic
public scala.Tuple2<java.lang.Object,java.lang.Object> materializeAtomic(StreamLayout.AtomicModule<Shape,java.lang.Object> mod, Attributes attributes)
- Specified by:
materializeAtomic
in interfacePhaseIsland<java.lang.Object>
-
name
public java.lang.String name()
- Specified by:
name
in interfacePhaseIsland<java.lang.Object>
-
onIslandReady
public void onIslandReady()
- Specified by:
onIslandReady
in interfacePhaseIsland<java.lang.Object>
-
subscriberOrVirtualPublisher
public java.lang.Object subscriberOrVirtualPublisher()
-
subscriberOrVirtualPublisher_$eq
public void subscriberOrVirtualPublisher_$eq(java.lang.Object x$1)
-
takePublisher
public void takePublisher(int slot, org.reactivestreams.Publisher<java.lang.Object> publisher)
- Specified by:
takePublisher
in interfacePhaseIsland<java.lang.Object>
-
-