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 SummaryAll 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- 
flowpublic Flow<ByteString,ByteString,NotUsed> flow() A flow representing the client on the other side of the connection. This flow can be materialized only once.
 - 
handleWithpublic <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.
 - 
handleWithpublic <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
 - 
localAddresspublic java.net.InetSocketAddress localAddress() The local address this connection is bound to.
 - 
remoteAddresspublic java.net.InetSocketAddress remoteAddress() The remote address this connection is bound to.
 
- 
 
-