Package akka.http.scaladsl
Class Http.IncomingConnection
java.lang.Object
akka.http.scaladsl.Http.IncomingConnection
- All Implemented Interfaces:
Serializable
,scala.Equals
,scala.Product
- Enclosing class:
- Http
public static final class Http.IncomingConnection
extends Object
implements scala.Product, Serializable
Represents one accepted incoming HTTP connection.
- See Also:
-
Constructor Summary
ConstructorDescriptionIncomingConnection
(InetSocketAddress localAddress, InetSocketAddress remoteAddress, akka.stream.scaladsl.Flow<HttpResponse, HttpRequest, ServerTerminator> _flow) -
Method Summary
Modifier and TypeMethodDescriptionakka.stream.scaladsl.Flow<HttpResponse,
HttpRequest, ServerTerminator> _flow()
akka.stream.scaladsl.Flow<HttpResponse,
HttpRequest, akka.NotUsed> flow()
<Mat> Mat
handleWith
(akka.stream.scaladsl.Flow<HttpRequest, HttpResponse, Mat> handler, akka.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, akka.stream.Materializer fm) Handles the connection with the given handler function.void
handleWithSyncHandler
(scala.Function1<HttpRequest, HttpResponse> handler, akka.stream.Materializer fm) Handles the connection with the given handler function.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface scala.Equals
canEqual, equals
Methods inherited from interface scala.Product
productArity, productElement, productElementName, productElementNames, productIterator, productPrefix
-
Constructor Details
-
IncomingConnection
public IncomingConnection(InetSocketAddress localAddress, InetSocketAddress remoteAddress, akka.stream.scaladsl.Flow<HttpResponse, HttpRequest, ServerTerminator> _flow)
-
-
Method Details
-
localAddress
-
remoteAddress
-
_flow
-
flow
-
handleWith
public <Mat> Mat handleWith(akka.stream.scaladsl.Flow<HttpRequest, HttpResponse, Mat> handler, akka.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, akka.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, akka.stream.Materializer fm) Handles the connection with the given handler function.- Parameters:
handler
- (undocumented)parallelism
- (undocumented)fm
- (undocumented)
-