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.ObjectRepresents an accepted incoming TCP connection.
-
-
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> MathandleWith(Flow<ByteString,ByteString,Mat> handler, ClassicActorSystemProvider systemProvider)Handles the connection using the given flow, which is materialized exactly once and the respective materialized value is returned.<Mat> MathandleWith(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.InetSocketAddresslocalAddress()The local address this connection is bound to.java.net.InetSocketAddressremoteAddress()The remote address this connection is bound to.
-
-
-
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.
-
handleWith
public <Mat> Mat handleWith(Flow<ByteString,ByteString,Mat> handler, ClassicActorSystemProvider systemProvider)
Handles the connection using the given flow, which is materialized exactly once and the respective materialized value is returned.Convenience shortcut for:
flow.joinMat(handler, Keep.right).run(systemProvider).Note that the classic or typed
ActorSystemcan be used as thesystemProviderparameter.
-
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.joinMat(handler, Keep.right).run(materializer).Prefer the method taking an
ActorSystemunless you have special requirements
-
localAddress
public java.net.InetSocketAddress localAddress()
The local address this connection is bound to.
-
remoteAddress
public java.net.InetSocketAddress remoteAddress()
The remote address this connection is bound to.
-
-