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

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)

Methods inherited from class java.lang.Object

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

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

assignPort

public void assignPort(OutPort out,
                       int slot,
                       java.lang.Object logic)

Specified by:

assignPort in interface PhaseIsland<java.lang.Object>

createPublisher

public org.reactivestreams.Publisher<java.lang.Object> createPublisher(OutPort out,
                                                                       java.lang.Object logic)

Specified by:

createPublisher in interface PhaseIsland<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 interface PhaseIsland<java.lang.Object>

name

public java.lang.String name()

Specified by:

name in interface PhaseIsland<java.lang.Object>

onIslandReady

public void onIslandReady()

Specified by:

onIslandReady in interface PhaseIsland<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 interface PhaseIsland<java.lang.Object>