Package akka.stream.impl
Interface PhaseIsland<M>
-
- All Known Implementing Classes:
GraphStageIsland
,ProcessorModulePhase
,SinkModulePhase
,SourceModulePhase
,TlsModulePhase
public interface PhaseIsland<M>
INTERNAL API
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
assignPort(InPort in, int slot, M logic)
void
assignPort(OutPort out, int slot, M logic)
org.reactivestreams.Publisher<java.lang.Object>
createPublisher(OutPort out, M logic)
scala.Tuple2<M,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)
-
-
-
Method Detail
-
createPublisher
org.reactivestreams.Publisher<java.lang.Object> createPublisher(OutPort out, M logic)
-
materializeAtomic
scala.Tuple2<M,java.lang.Object> materializeAtomic(StreamLayout.AtomicModule<Shape,java.lang.Object> mod, Attributes attributes)
-
name
java.lang.String name()
-
onIslandReady
void onIslandReady()
-
takePublisher
void takePublisher(int slot, org.reactivestreams.Publisher<java.lang.Object> publisher)
-
-