Package akka.stream.impl

Class TlsModulePhase

java.lang.Object

akka.stream.impl.TlsModulePhase

All Implemented Interfaces:

PhaseIsland<NotUsed>

public final class TlsModulePhase
extends java.lang.Object
implements PhaseIsland<NotUsed>

INTERNAL API

Constructor Summary

Constructors

Constructor	Description
TlsModulePhase(PhasedFusingActorMaterializer materializer, java.lang.String islandName)

Method Summary

Modifier and Type	Method	Description
void	assignPort(InPort in, int slot, NotUsed logic)
void	assignPort(OutPort out, int slot, NotUsed logic)
org.reactivestreams.Publisher<java.lang.Object>	createPublisher(OutPort out, NotUsed logic)
scala.Tuple2<NotUsed,java.lang.Object>	materializeAtomic(StreamLayout.AtomicModule<Shape,java.lang.Object> mod, Attributes attributes)
java.lang.String	name()
void	onIslandReady()
scala.collection.immutable.Vector<ActorPublisher<java.lang.Object>>	publishers()
void	publishers_$eq(scala.collection.immutable.Vector<ActorPublisher<java.lang.Object>> x$1)
void	takePublisher(int slot, org.reactivestreams.Publisher<java.lang.Object> publisher)
ActorRef	tlsActor()
void	tlsActor_$eq(ActorRef x$1)

Methods inherited from class java.lang.Object

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

Constructor Detail

TlsModulePhase

public TlsModulePhase(PhasedFusingActorMaterializer materializer,
                      java.lang.String islandName)

Method Detail

assignPort

public void assignPort(InPort in,
                       int slot,
                       NotUsed logic)

Specified by:

assignPort in interface PhaseIsland<NotUsed>

assignPort

public void assignPort(OutPort out,
                       int slot,
                       NotUsed logic)

Specified by:

assignPort in interface PhaseIsland<NotUsed>

createPublisher

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

Specified by:

createPublisher in interface PhaseIsland<NotUsed>

materializeAtomic

public scala.Tuple2<NotUsed,java.lang.Object> materializeAtomic(StreamLayout.AtomicModule<Shape,java.lang.Object> mod,
                                                                      Attributes attributes)

Specified by:

materializeAtomic in interface PhaseIsland<NotUsed>

name

public java.lang.String name()

Specified by:

name in interface PhaseIsland<NotUsed>

onIslandReady

public void onIslandReady()

Specified by:

onIslandReady in interface PhaseIsland<NotUsed>

publishers

public scala.collection.immutable.Vector<ActorPublisher<java.lang.Object>> publishers()

publishers_$eq

public void publishers_$eq(scala.collection.immutable.Vector<ActorPublisher<java.lang.Object>> x$1)

takePublisher

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

Specified by:

takePublisher in interface PhaseIsland<NotUsed>

tlsActor

public ActorRef tlsActor()

tlsActor_$eq

public void tlsActor_$eq(ActorRef x$1)