org.apache.pekko.http.scaladsl

Class Http.IncomingConnection

java.lang.Object

org.apache.pekko.http.scaladsl.Http.IncomingConnection

All Implemented Interfaces:

java.io.Serializable, scala.Equals, scala.Product

Enclosing class:

Http

public static final class Http.IncomingConnection
extends java.lang.Object
implements scala.Product, java.io.Serializable

Represents one accepted incoming HTTP connection.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
IncomingConnection(java.net.InetSocketAddress localAddress, java.net.InetSocketAddress remoteAddress, org.apache.pekko.stream.scaladsl.Flow<HttpResponse,HttpRequest,ServerTerminator> _flow)

Method Summary

Modifier and Type	Method and Description
org.apache.pekko.stream.scaladsl.Flow<HttpResponse,HttpRequest,ServerTerminator>	_flow()
org.apache.pekko.stream.scaladsl.Flow<HttpResponse,HttpRequest,org.apache.pekko.NotUsed>	flow()
<Mat> Mat	handleWith(org.apache.pekko.stream.scaladsl.Flow<HttpRequest,HttpResponse,Mat> handler, org.apache.pekko.stream.Materializer fm) Handles the connection with the given flow, which is materialized exactly once and the respective materialization result returned.
void	handleWithAsyncHandler(scala.Function1<HttpRequest,scala.concurrent.Future<HttpResponse>> handler, int parallelism, org.apache.pekko.stream.Materializer fm) Handles the connection with the given handler function.
void	handleWithSyncHandler(scala.Function1<HttpRequest,HttpResponse> handler, org.apache.pekko.stream.Materializer fm) Handles the connection with the given handler function.
java.net.InetSocketAddress	localAddress()
java.net.InetSocketAddress	remoteAddress()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface scala.Product

$init$, productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

IncomingConnection

public IncomingConnection(java.net.InetSocketAddress localAddress,
                          java.net.InetSocketAddress remoteAddress,
                          org.apache.pekko.stream.scaladsl.Flow<HttpResponse,HttpRequest,ServerTerminator> _flow)

Method Detail

localAddress

public java.net.InetSocketAddress localAddress()

remoteAddress

public java.net.InetSocketAddress remoteAddress()

_flow

public org.apache.pekko.stream.scaladsl.Flow<HttpResponse,HttpRequest,ServerTerminator> _flow()

flow

public org.apache.pekko.stream.scaladsl.Flow<HttpResponse,HttpRequest,org.apache.pekko.NotUsed> flow()

handleWith

public <Mat> Mat handleWith(org.apache.pekko.stream.scaladsl.Flow<HttpRequest,HttpResponse,Mat> handler,
                            org.apache.pekko.stream.Materializer fm)

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

Parameters:

handler - (undocumented)

fm - (undocumented)

Returns:

(undocumented)

handleWithSyncHandler

public void handleWithSyncHandler(scala.Function1<HttpRequest,HttpResponse> handler,
                                  org.apache.pekko.stream.Materializer fm)

Handles the connection with the given handler function.

Parameters:

handler - (undocumented)

fm - (undocumented)

handleWithAsyncHandler

public void handleWithAsyncHandler(scala.Function1<HttpRequest,scala.concurrent.Future<HttpResponse>> handler,
                                   int parallelism,
                                   org.apache.pekko.stream.Materializer fm)

Handles the connection with the given handler function.

Parameters:

handler - (undocumented)

parallelism - (undocumented)

fm - (undocumented)