Package akka.stream.impl.io
Class ConnectionSourceStage
- java.lang.Object
-
- akka.stream.stage.GraphStageWithMaterializedValue<SourceShape<Tcp.IncomingConnection>,scala.concurrent.Future<Tcp.ServerBinding>>
-
- akka.stream.impl.io.ConnectionSourceStage
-
- All Implemented Interfaces:
Graph<SourceShape<Tcp.IncomingConnection>,scala.concurrent.Future<Tcp.ServerBinding>>
public class ConnectionSourceStage extends GraphStageWithMaterializedValue<SourceShape<Tcp.IncomingConnection>,scala.concurrent.Future<Tcp.ServerBinding>>
INTERNAL API
-
-
Constructor Summary
Constructors Constructor Description ConnectionSourceStage(ActorRef tcpManager, java.net.InetSocketAddress endpoint, int backlog, scala.collection.immutable.Iterable<Inet.SocketOption> options, boolean halfClose, scala.concurrent.duration.Duration idleTimeout, scala.concurrent.duration.FiniteDuration bindShutdownTimeout, IOSettings ioSettings)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description 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()
IOSettings
ioSettings()
scala.collection.immutable.Iterable<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()
-
Methods inherited from class akka.stream.stage.GraphStageWithMaterializedValue
createLogicAndMaterializedValue, traversalBuilder, withAttributes
-
-
-
-
Constructor Detail
-
ConnectionSourceStage
public ConnectionSourceStage(ActorRef tcpManager, java.net.InetSocketAddress endpoint, int backlog, scala.collection.immutable.Iterable<Inet.SocketOption> options, boolean halfClose, scala.concurrent.duration.Duration idleTimeout, scala.concurrent.duration.FiniteDuration bindShutdownTimeout, IOSettings ioSettings)
-
-
Method Detail
-
BindTimer
public static java.lang.String BindTimer()
-
BindShutdownTimer
public static java.lang.String BindShutdownTimer()
-
tcpManager
public ActorRef tcpManager()
-
endpoint
public java.net.InetSocketAddress endpoint()
-
backlog
public int backlog()
-
options
public scala.collection.immutable.Iterable<Inet.SocketOption> options()
-
halfClose
public boolean halfClose()
-
idleTimeout
public scala.concurrent.duration.Duration idleTimeout()
-
bindShutdownTimeout
public scala.concurrent.duration.FiniteDuration bindShutdownTimeout()
-
ioSettings
public IOSettings ioSettings()
-
out
public Outlet<Tcp.IncomingConnection> out()
-
initialAttributes
public Attributes initialAttributes()
- Overrides:
initialAttributes
in classGraphStageWithMaterializedValue<SourceShape<Tcp.IncomingConnection>,scala.concurrent.Future<Tcp.ServerBinding>>
-
shape
public SourceShape<Tcp.IncomingConnection> shape()
Description copied from interface:Graph
The shape of a graph is all that is externally visible: its inlets and outlets.- Returns:
- (undocumented)
-
createLogicAndMaterializedValue
public scala.Tuple2<GraphStageLogic,scala.concurrent.Future<Tcp.ServerBinding>> createLogicAndMaterializedValue(Attributes inheritedAttributes)
- Specified by:
createLogicAndMaterializedValue
in classGraphStageWithMaterializedValue<SourceShape<Tcp.IncomingConnection>,scala.concurrent.Future<Tcp.ServerBinding>>
-
-