public class IncomingConnection
extends java.lang.Object
Constructor and Description |
---|
IncomingConnection(Http.IncomingConnection delegate) |
Modifier and Type | Method and Description |
---|---|
org.apache.pekko.stream.javadsl.Flow<HttpResponse,HttpRequest,org.apache.pekko.NotUsed> |
flow()
A flow representing the incoming requests and outgoing responses for this connection.
|
<Mat> Mat |
handleWith(org.apache.pekko.stream.javadsl.Flow<HttpRequest,HttpResponse,Mat> handler,
org.apache.pekko.stream.Materializer materializer)
Handles the connection with the given flow, which is materialized exactly once
and the respective materialization result returned.
|
void |
handleWithAsyncHandler(org.apache.pekko.japi.function.Function<HttpRequest,java.util.concurrent.CompletionStage<HttpResponse>> handler,
int parallelism,
org.apache.pekko.stream.Materializer materializer)
Handles the connection with the given handler function.
|
void |
handleWithAsyncHandler(org.apache.pekko.japi.function.Function<HttpRequest,java.util.concurrent.CompletionStage<HttpResponse>> handler,
org.apache.pekko.stream.Materializer materializer)
Handles the connection with the given handler function.
|
void |
handleWithSyncHandler(org.apache.pekko.japi.function.Function<HttpRequest,HttpResponse> handler,
org.apache.pekko.stream.Materializer materializer)
Handles the connection with the given handler function.
|
java.net.InetSocketAddress |
localAddress()
The local address of this connection.
|
java.net.InetSocketAddress |
remoteAddress()
The address of the remote peer.
|
public IncomingConnection(Http.IncomingConnection delegate)
public org.apache.pekko.stream.javadsl.Flow<HttpResponse,HttpRequest,org.apache.pekko.NotUsed> flow()
Use Flow.join
or one of the handleXXX methods to consume handle requests on this connection.
public <Mat> Mat handleWith(org.apache.pekko.stream.javadsl.Flow<HttpRequest,HttpResponse,Mat> handler, org.apache.pekko.stream.Materializer materializer)
handler
- (undocumented)materializer
- (undocumented)public void handleWithAsyncHandler(org.apache.pekko.japi.function.Function<HttpRequest,java.util.concurrent.CompletionStage<HttpResponse>> handler, org.apache.pekko.stream.Materializer materializer)
handler
- (undocumented)materializer
- (undocumented)public void handleWithAsyncHandler(org.apache.pekko.japi.function.Function<HttpRequest,java.util.concurrent.CompletionStage<HttpResponse>> handler, int parallelism, org.apache.pekko.stream.Materializer materializer)
handler
- (undocumented)parallelism
- (undocumented)materializer
- (undocumented)public void handleWithSyncHandler(org.apache.pekko.japi.function.Function<HttpRequest,HttpResponse> handler, org.apache.pekko.stream.Materializer materializer)
handler
- (undocumented)materializer
- (undocumented)public java.net.InetSocketAddress localAddress()
public java.net.InetSocketAddress remoteAddress()