final case class IncomingConnection(localAddress: InetSocketAddress, remoteAddress: InetSocketAddress, flow: Flow[ByteString, ByteString, NotUsed]) extends Product with Serializable
- Alphabetic
- By Inheritance
- IncomingConnection
- Serializable
- Serializable
- Product
- Equals
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Instance Constructors
- new IncomingConnection(localAddress: InetSocketAddress, remoteAddress: InetSocketAddress, flow: Flow[ByteString, ByteString, NotUsed])
Value Members
- val flow: Flow[ByteString, ByteString, NotUsed]
-
def
handleWith[Mat](handler: Flow[ByteString, 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.join(handler).run()
. - val localAddress: InetSocketAddress
- val remoteAddress: InetSocketAddress