Package akka.stream.impl
Class SourceModulePhase
- java.lang.Object
-
- akka.stream.impl.SourceModulePhase
-
- All Implemented Interfaces:
PhaseIsland<org.reactivestreams.Publisher<java.lang.Object>>
public final class SourceModulePhase extends java.lang.Object implements PhaseIsland<org.reactivestreams.Publisher<java.lang.Object>>
INTERNAL API
-
-
Constructor Summary
Constructors Constructor Description SourceModulePhase(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, org.reactivestreams.Publisher<java.lang.Object> logic)
void
assignPort(OutPort out, int slot, org.reactivestreams.Publisher<java.lang.Object> logic)
org.reactivestreams.Publisher<java.lang.Object>
createPublisher(OutPort out, org.reactivestreams.Publisher<java.lang.Object> logic)
scala.Tuple2<org.reactivestreams.Publisher<java.lang.Object>,java.lang.Object>
materializeAtomic(StreamLayout.AtomicModule<Shape,java.lang.Object> mod, Attributes attributes)
java.lang.String
name()
void
onIslandReady()
void
takePublisher(int slot, org.reactivestreams.Publisher<java.lang.Object> publisher)
-
-
-
Constructor Detail
-
SourceModulePhase
public SourceModulePhase(PhasedFusingActorMaterializer materializer, java.lang.String islandName)
-
-
Method Detail
-
assignPort
public void assignPort(InPort in, int slot, org.reactivestreams.Publisher<java.lang.Object> logic)
- Specified by:
assignPort
in interfacePhaseIsland<org.reactivestreams.Publisher<java.lang.Object>>
-
assignPort
public void assignPort(OutPort out, int slot, org.reactivestreams.Publisher<java.lang.Object> logic)
- Specified by:
assignPort
in interfacePhaseIsland<org.reactivestreams.Publisher<java.lang.Object>>
-
createPublisher
public org.reactivestreams.Publisher<java.lang.Object> createPublisher(OutPort out, org.reactivestreams.Publisher<java.lang.Object> logic)
- Specified by:
createPublisher
in interfacePhaseIsland<org.reactivestreams.Publisher<java.lang.Object>>
-
materializeAtomic
public scala.Tuple2<org.reactivestreams.Publisher<java.lang.Object>,java.lang.Object> materializeAtomic(StreamLayout.AtomicModule<Shape,java.lang.Object> mod, Attributes attributes)
- Specified by:
materializeAtomic
in interfacePhaseIsland<org.reactivestreams.Publisher<java.lang.Object>>
-
name
public java.lang.String name()
- Specified by:
name
in interfacePhaseIsland<org.reactivestreams.Publisher<java.lang.Object>>
-
onIslandReady
public void onIslandReady()
- Specified by:
onIslandReady
in interfacePhaseIsland<org.reactivestreams.Publisher<java.lang.Object>>
-
takePublisher
public void takePublisher(int slot, org.reactivestreams.Publisher<java.lang.Object> publisher)
- Specified by:
takePublisher
in interfacePhaseIsland<org.reactivestreams.Publisher<java.lang.Object>>
-
-