Package akka.stream.impl

Interface PhaseIsland<M>

All Known Implementing Classes:

GraphStageIsland, ProcessorModulePhase, SinkModulePhase, SourceModulePhase, TlsModulePhase

public interface PhaseIsland<M>

INTERNAL API

Method Summary

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

assignPort

void assignPort(InPort in,
                int slot,
                M logic)

assignPort

void assignPort(OutPort out,
                int slot,
                M logic)

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)