public class ConnectionSourceStage extends GraphStageWithMaterializedValue<SourceShape<Tcp.IncomingConnection>,scala.concurrent.Future<Tcp.ServerBinding>>
Constructor and Description |
---|
ConnectionSourceStage(ActorRef tcpManager,
java.net.InetSocketAddress endpoint,
int backlog,
scala.collection.immutable.Traversable<Inet.SocketOption> options,
boolean halfClose,
scala.concurrent.duration.Duration idleTimeout,
scala.concurrent.duration.FiniteDuration bindShutdownTimeout) |
Modifier and Type | Method and Description |
---|---|
static Graph<S,M> |
addAttributes(Attributes attr) |
static Graph<S,M> |
async() |
int |
backlog() |
scala.concurrent.duration.FiniteDuration |
bindShutdownTimeout() |
static java.lang.String |
BindShutdownTimer() |
static java.lang.String |
BindTimer() |
scala.Tuple2<GraphStageLogic,scala.concurrent.Future<Tcp.ServerBinding>> |
createLogicAndMaterializedValue(Attributes inheritedAttributes) |
java.net.InetSocketAddress |
endpoint() |
boolean |
halfClose() |
scala.concurrent.duration.Duration |
idleTimeout() |
Attributes |
initialAttributes() |
static StreamLayout.Module |
module() |
static Graph<S,M> |
named(java.lang.String name) |
scala.collection.immutable.Traversable<Inet.SocketOption> |
options() |
Outlet<Tcp.IncomingConnection> |
out() |
SourceShape<Tcp.IncomingConnection> |
shape()
The shape of a graph is all that is externally visible: its inlets and outlets.
|
ActorRef |
tcpManager() |
static Graph<S,M> |
withAttributes(Attributes attr) |
module, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addAttributes, async, named
public ConnectionSourceStage(ActorRef tcpManager, java.net.InetSocketAddress endpoint, int backlog, scala.collection.immutable.Traversable<Inet.SocketOption> options, boolean halfClose, scala.concurrent.duration.Duration idleTimeout, scala.concurrent.duration.FiniteDuration bindShutdownTimeout)
public static java.lang.String BindTimer()
public static java.lang.String BindShutdownTimer()
public static Graph<S,M> named(java.lang.String name)
public static Graph<S,M> async()
public static Graph<S,M> addAttributes(Attributes attr)
public static final StreamLayout.Module module()
public static final Graph<S,M> withAttributes(Attributes attr)
public ActorRef tcpManager()
public java.net.InetSocketAddress endpoint()
public int backlog()
public scala.collection.immutable.Traversable<Inet.SocketOption> options()
public boolean halfClose()
public scala.concurrent.duration.Duration idleTimeout()
public scala.concurrent.duration.FiniteDuration bindShutdownTimeout()
public Outlet<Tcp.IncomingConnection> out()
public Attributes initialAttributes()
initialAttributes
in class GraphStageWithMaterializedValue<SourceShape<Tcp.IncomingConnection>,scala.concurrent.Future<Tcp.ServerBinding>>
public SourceShape<Tcp.IncomingConnection> shape()
Graph
public scala.Tuple2<GraphStageLogic,scala.concurrent.Future<Tcp.ServerBinding>> createLogicAndMaterializedValue(Attributes inheritedAttributes)
createLogicAndMaterializedValue
in class GraphStageWithMaterializedValue<SourceShape<Tcp.IncomingConnection>,scala.concurrent.Future<Tcp.ServerBinding>>