public static final class Tcp.IncomingConnection
extends java.lang.Object
implements scala.Product, scala.Serializable
Constructor and Description |
---|
IncomingConnection(java.net.InetSocketAddress localAddress,
java.net.InetSocketAddress remoteAddress,
Flow<ByteString,ByteString,NotUsed> flow) |
Modifier and Type | Method and Description |
---|---|
Flow<ByteString,ByteString,NotUsed> |
flow() |
<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 instance is returned.
|
java.net.InetSocketAddress |
localAddress() |
java.net.InetSocketAddress |
remoteAddress() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public IncomingConnection(java.net.InetSocketAddress localAddress, java.net.InetSocketAddress remoteAddress, Flow<ByteString,ByteString,NotUsed> flow)
public java.net.InetSocketAddress localAddress()
public java.net.InetSocketAddress remoteAddress()
public Flow<ByteString,ByteString,NotUsed> flow()
public <Mat> Mat handleWith(Flow<ByteString,ByteString,Mat> handler, Materializer materializer)
Convenience shortcut for: flow.join(handler).run()
.
handler
- (undocumented)materializer
- (undocumented)