Package akka.stream.impl.io
Class TcpConnectionStage.TcpStreamLogic
- java.lang.Object
-
- akka.stream.stage.GraphStageLogic
-
- akka.stream.impl.io.TcpConnectionStage.TcpStreamLogic
-
- Enclosing class:
- TcpConnectionStage
public static class TcpConnectionStage.TcpStreamLogic extends GraphStageLogic
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class akka.stream.stage.GraphStageLogic
GraphStageLogic.ConditionalTerminateInput, GraphStageLogic.ConditionalTerminateOutput, GraphStageLogic.EagerTerminateInput$, GraphStageLogic.EagerTerminateOutput$, GraphStageLogic.IgnoreTerminateInput$, GraphStageLogic.IgnoreTerminateOutput$, GraphStageLogic.StageActor, GraphStageLogic.StageActorRef$, GraphStageLogic.StageActorRefNotInitializedException, GraphStageLogic.StageActorRefNotInitializedException$, GraphStageLogic.SubSinkInlet<T>, GraphStageLogic.SubSourceOutlet<T>, GraphStageLogic.TotallyIgnorantInput$
-
-
Constructor Summary
Constructors Constructor Description TcpStreamLogic(FlowShape<ByteString,ByteString> shape, TcpConnectionStage.TcpRole role, java.net.InetSocketAddress remoteAddress)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
postStop()
Invoked after processing of external events stopped because the operator is about to stop or fail.void
preStart()
Invoked before any external events are processed, at the startup of the operator.java.lang.Object
readHandler()
TcpConnectionStage.TcpRole
role()
ActorRef
self()
FlowShape<ByteString,ByteString>
shape()
-
Methods inherited from class akka.stream.stage.GraphStageLogic
abortEmitting, abortReading, afterPostStop, attributes, attributes_$eq, beforePreStart, cancel, cancelStage, complete, completeStage, conditionalTerminateInput, conditionalTerminateOutput, createAsyncCallback, eagerTerminateInput, eagerTerminateOutput, emit, emit, emit, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, fail, failStage, getAsyncCallback, getEagerStageActor, getHandler, getHandler, getStageActor, grab, handlers, hasBeenPulled, ignoreTerminateInput, ignoreTerminateOutput, inCount, inHandler, interpreter, interpreter_$eq, isAvailable, isAvailable, isClosed, isClosed, materializer, NoPromise, onFeedbackDispatched, originalStage, originalStage_$eq, outCount, outHandler, passAlong, passAlong$default$3, passAlong$default$4, passAlong$default$5, portToConn, pull, push, read, read, readN, readN, setHandler, setHandler, setHandlers, setKeepGoing, stageActor, stageActorName, stageId, stageId_$eq, subFusingMaterializer, totallyIgnorantInput, tryPull
-
-
-
-
Constructor Detail
-
TcpStreamLogic
public TcpStreamLogic(FlowShape<ByteString,ByteString> shape, TcpConnectionStage.TcpRole role, java.net.InetSocketAddress remoteAddress)
-
-
Method Detail
-
postStop
public void postStop()
Description copied from class:GraphStageLogic
Invoked after processing of external events stopped because the operator is about to stop or fail.- Overrides:
postStop
in classGraphStageLogic
-
preStart
public void preStart()
Description copied from class:GraphStageLogic
Invoked before any external events are processed, at the startup of the operator.- Overrides:
preStart
in classGraphStageLogic
-
readHandler
public java.lang.Object readHandler()
-
role
public TcpConnectionStage.TcpRole role()
-
self
public ActorRef self()
-
shape
public FlowShape<ByteString,ByteString> shape()
-
-