public static class TcpConnectionStage.TcpStreamLogic extends 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 and Description |
---|
TcpStreamLogic(FlowShape<ByteString,ByteString> shape,
TcpConnectionStage.TcpRole role,
java.net.InetSocketAddress remoteAddress) |
Modifier and Type | Method and Description |
---|---|
void |
postStop()
Invoked after processing of external events stopped because the stage is about to stop or fail.
|
void |
preStart()
Invoked before any external events are processed, at the startup of the stage.
|
java.lang.Object |
readHandler() |
TcpConnectionStage.TcpRole |
role() |
ActorRef |
self() |
FlowShape<ByteString,ByteString> |
shape() |
abortEmitting, abortReading, afterPostStop, beforePreStart, cancel, complete, completeStage, conditionalTerminateInput, conditionalTerminateOutput, createAsyncCallback, eagerTerminateInput, eagerTerminateOutput, emit, emit, emit, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, fail, failStage, getAsyncCallback, getHandler, getHandler, getStageActor, grab, handlers, hasBeenPulled, ignoreTerminateInput, ignoreTerminateOutput, inCount, interpreter, isAvailable, isAvailable, isClosed, isClosed, materializer, outCount, passAlong, portToConn, pull, push, read, read, readN, readN, setHandler, setHandler, setHandlers, setKeepGoing, stageActor, stageId, subFusingMaterializer, totallyIgnorantInput, tryPull
public TcpStreamLogic(FlowShape<ByteString,ByteString> shape, TcpConnectionStage.TcpRole role, java.net.InetSocketAddress remoteAddress)
public FlowShape<ByteString,ByteString> shape()
public TcpConnectionStage.TcpRole role()
public ActorRef self()
public void preStart()
GraphStageLogic
preStart
in class GraphStageLogic
public java.lang.Object readHandler()
public void postStop()
GraphStageLogic
postStop
in class GraphStageLogic