public class IncomingConnectionStage extends GraphStage<FlowShape<ByteString,ByteString>>
Constructor and Description |
---|
IncomingConnectionStage(ActorRef connection,
java.net.InetSocketAddress remoteAddress,
boolean halfClose) |
Modifier and Type | Method and Description |
---|---|
Inlet<ByteString> |
bytesIn() |
Outlet<ByteString> |
bytesOut() |
GraphStageLogic |
createLogic(Attributes inheritedAttributes) |
Attributes |
initialAttributes() |
FlowShape<ByteString,ByteString> |
shape()
The shape of a graph is all that is externally visible: its inlets and outlets.
|
java.lang.String |
toString() |
createLogicAndMaterializedValue
module, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addAttributes, async, named
public IncomingConnectionStage(ActorRef connection, java.net.InetSocketAddress remoteAddress, boolean halfClose)
public Inlet<ByteString> bytesIn()
public Outlet<ByteString> bytesOut()
public Attributes initialAttributes()
initialAttributes
in class GraphStageWithMaterializedValue<FlowShape<ByteString,ByteString>,NotUsed>
public FlowShape<ByteString,ByteString> shape()
Graph
public GraphStageLogic createLogic(Attributes inheritedAttributes)
createLogic
in class GraphStage<FlowShape<ByteString,ByteString>>
public java.lang.String toString()
toString
in class java.lang.Object