Struct Tcp.IncomingConnection

Represents an accepted incoming TCP connection.

Inherited Members
Namespace: Akka.Streams.Dsl
Assembly: Akka.Streams.dll
Syntax
public readonly struct IncomingConnection

Constructors

| Improve this Doc View Source

IncomingConnection(EndPoint, EndPoint, Flow<ByteString, ByteString, NotUsed>)

Initializes a new instance of the Tcp.IncomingConnection class.

Declaration
public IncomingConnection(EndPoint localAddress, EndPoint remoteAddress, Flow<ByteString, ByteString, NotUsed> flow)
Parameters
Type Name Description
EndPoint localAddress

TBD
EndPoint remoteAddress

TBD
Flow<ByteString, ByteString, NotUsed> flow

TBD

Fields

| Improve this Doc View Source

Flow

TBD

Declaration
public readonly Flow<ByteString, ByteString, NotUsed> Flow
Field Value
Type Description
Flow<ByteString, ByteString, NotUsed>
| Improve this Doc View Source

LocalAddress

TBD

Declaration
public readonly EndPoint LocalAddress
Field Value
Type Description
EndPoint
| Improve this Doc View Source

RemoteAddress

TBD

Declaration
public readonly EndPoint RemoteAddress
Field Value
Type Description
EndPoint

Methods

| Improve this Doc View Source

HandleWith<TMat>(Flow<ByteString, ByteString, TMat>, IMaterializer)

Handles the connection using the given flow, which is materialized exactly once and the respective materialized instance is returned.

Convenience shortcut for: flow.join(handler).run().

Declaration
public readonly TMat HandleWith<TMat>(Flow<ByteString, ByteString, TMat> handler, IMaterializer materializer)
Parameters
Type Name Description
Flow<ByteString, ByteString, TMat> handler

TBD
IMaterializer materializer

TBD
Returns
Type Description
TMat

TBD
Type Parameters
Name Description
TMat

TBD

Extension Methods