Packages

c

org.apache.pekko.http.javadsl

IncomingConnection

class IncomingConnection extends AnyRef

Represents one accepted incoming HTTP connection.

Source
IncomingConnection.scala
Linear Supertypes
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. IncomingConnection
  2. AnyRef
  3. 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

Value Members

  1. def flow: Flow[HttpResponse, HttpRequest, NotUsed]

    A flow representing the incoming requests and outgoing responses for this connection.

    A flow representing the incoming requests and outgoing responses for this connection.

    Use Flow.join or one of the handleXXX methods to consume handle requests on this connection.

  2. def handleWith[Mat](handler: Flow[HttpRequest, HttpResponse, Mat], materializer: Materializer): Mat

    Handles the connection with the given flow, which is materialized exactly once and the respective materialization result returned.

  3. def handleWithAsyncHandler(handler: Function[HttpRequest, CompletionStage[HttpResponse]], parallelism: Int, materializer: Materializer): Unit

    Handles the connection with the given handler function.

  4. def handleWithAsyncHandler(handler: Function[HttpRequest, CompletionStage[HttpResponse]], materializer: Materializer): Unit

    Handles the connection with the given handler function.

  5. def handleWithSyncHandler(handler: Function[HttpRequest, HttpResponse], materializer: Materializer): Unit

    Handles the connection with the given handler function.

  6. def localAddress: InetSocketAddress

    The local address of this connection.

  7. def remoteAddress: InetSocketAddress

    The address of the remote peer.