Package akka.stream.javadsl
Class Tcp.IncomingConnection
- java.lang.Object
-
- akka.stream.javadsl.Tcp.IncomingConnection
-
- Enclosing class:
- Tcp
public static class Tcp.IncomingConnection extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description IncomingConnection(Tcp.IncomingConnection delegate)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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()
java.net.InetSocketAddress
remoteAddress()
The remote address this connection is bound to.
-
-
-
Constructor Detail
-
IncomingConnection
public IncomingConnection(Tcp.IncomingConnection delegate)
-
-
Method Detail
-
flow
public Flow<ByteString,ByteString,NotUsed> flow()
A flow representing the client on the other side of the connection. This flow can be materialized only once.- Returns:
- (undocumented)
-
handleWith
public <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.Convenience shortcut for:
flow.join(handler).run()
.- Parameters:
handler
- (undocumented)materializer
- (undocumented)- Returns:
- (undocumented)
-
localAddress
public java.net.InetSocketAddress localAddress()
-
remoteAddress
public java.net.InetSocketAddress remoteAddress()
The remote address this connection is bound to.- Returns:
- (undocumented)
-
-