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

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 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 class GraphStageLogic
  - 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 class GraphStageLogic
  - readHandler
```
public java.lang.Object readHandler()
```
  - role
```
public TcpConnectionStage.TcpRole role()
```
  - self
```
public ActorRef self()
```
  - shape
```
public FlowShape<ByteString,ByteString> shape()
```