Struct Tcp.IncomingConnection

Represents an accepted incoming TCP connection.

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

Constructors

| Edit this page 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

| Edit this page View Source

Flow

TBD

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

LocalAddress

TBD

Declaration
public readonly EndPoint LocalAddress
Field Value
Type Description
EndPoint
| Edit this page View Source

RemoteAddress

TBD

Declaration
public readonly EndPoint RemoteAddress
Field Value
Type Description
EndPoint

Methods

| Edit this page 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 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