c

akka.stream.scaladsl.Tcp

IncomingConnection

final case class IncomingConnection(localAddress: InetSocketAddress, remoteAddress: InetSocketAddress, flow: Flow[ByteString, ByteString, NotUsed]) extends Product with Serializable

Represents an accepted incoming TCP connection.

Source
Tcp.scala
Linear Supertypes
Serializable, Product, Equals, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. IncomingConnection
  2. Serializable
  3. Product
  4. Equals
  5. AnyRef
  6. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new IncomingConnection(localAddress: InetSocketAddress, remoteAddress: InetSocketAddress, flow: [, , NotUsed])

Value Members

  1. val flow: [, , NotUsed]
  2. def handleWith[Mat](handler: [, ByteString, Mat])(implicit materializer: Materializer): Mat

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

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

    Convenience shortcut for: flow.joinMat(handler)(Keep.right).run().

  3. val localAddress: InetSocketAddress
  4. def productElementNames: Iterator[String]
    Definition Classes
    Product
  5. val remoteAddress: InetSocketAddress