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
All Methods Instance Methods Concrete Methods 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)
-
-
-
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 interfacePhaseIsland<NotUsed>
-
assignPort
public void assignPort(OutPort out, int slot, NotUsed logic)
- Specified by:
assignPort
in interfacePhaseIsland<NotUsed>
-
createPublisher
public org.reactivestreams.Publisher<java.lang.Object> createPublisher(OutPort out, NotUsed logic)
- Specified by:
createPublisher
in interfacePhaseIsland<NotUsed>
-
materializeAtomic
public scala.Tuple2<NotUsed,java.lang.Object> materializeAtomic(StreamLayout.AtomicModule<Shape,java.lang.Object> mod, Attributes attributes)
- Specified by:
materializeAtomic
in interfacePhaseIsland<NotUsed>
-
name
public java.lang.String name()
- Specified by:
name
in interfacePhaseIsland<NotUsed>
-
onIslandReady
public void onIslandReady()
- Specified by:
onIslandReady
in interfacePhaseIsland<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 interfacePhaseIsland<NotUsed>
-
tlsActor
public ActorRef tlsActor()
-
tlsActor_$eq
public void tlsActor_$eq(ActorRef x$1)
-
-