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. 
 - 
 
 -