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

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)

Methods inherited from class java.lang.Object

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

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 interface PhaseIsland<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 interface PhaseIsland<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 interface PhaseIsland<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 interface PhaseIsland<org.reactivestreams.Publisher<java.lang.Object>>

name

public java.lang.String name()

Specified by:

name in interface PhaseIsland<org.reactivestreams.Publisher<java.lang.Object>>

onIslandReady

public void onIslandReady()

Specified by:

onIslandReady in interface PhaseIsland<org.reactivestreams.Publisher<java.lang.Object>>

takePublisher

public void takePublisher(int slot,
                          org.reactivestreams.Publisher<java.lang.Object> publisher)

Specified by:

takePublisher in interface PhaseIsland<org.reactivestreams.Publisher<java.lang.Object>>