public static class Tcp.IncomingConnection
extends java.lang.Object
Constructor and Description |
---|
IncomingConnection(Tcp.IncomingConnection delegate) |
Modifier and Type | Method and Description |
---|---|
Flow<ByteString,ByteString,NotUsed> |
flow()
A flow representing the client on the other side of the connection.
|
<Mat> Mat |
handleWith(Flow<ByteString,ByteString,Mat> handler,
Materializer materializer)
Handles the connection using the given flow, which is materialized exactly once and the respective
materialized value is returned.
|
java.net.InetSocketAddress |
localAddress()
The local address this connection is bound to.
|
java.net.InetSocketAddress |
remoteAddress()
The remote address this connection is bound to.
|
public IncomingConnection(Tcp.IncomingConnection delegate)
public java.net.InetSocketAddress localAddress()
public java.net.InetSocketAddress remoteAddress()
public <Mat> Mat handleWith(Flow<ByteString,ByteString,Mat> handler, Materializer materializer)
Convenience shortcut for: flow.join(handler).run()
.
handler
- (undocumented)materializer
- (undocumented)public Flow<ByteString,ByteString,NotUsed> flow()