public class HttpServerBluePrint$
extends java.lang.Object
HTTP pipeline setup (without the underlying SSL/TLS (un)wrapping and the websocket switch):
+----------+ +-------------+ +-------------+ +-----------+ HttpRequest | | Http- | request- | Request- | | Request- | request- | ByteString | <------------+ <----------+ Preparation <----------+ <-------------+ Parsing <----------- | | | Request | | Output | | Output | | | | | +-------------+ | | +-----------+ | | | | | | Application- | One2One- | | controller- | | Flow | Bidi | | Stage | | | | | | | | | | | +-----------+ | HttpResponse | | HttpResponse | | Response- | renderer- | ByteString v -------------> +-----------------------------------> +-------------> Pipeline +----------> | | | | Rendering- | | +----------+ +-------------+ Context +-----------+
Modifier and Type | Field and Description |
---|---|
static HttpServerBluePrint$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
HttpServerBluePrint$() |
Modifier and Type | Method and Description |
---|---|
akka.stream.scaladsl.BidiFlow<HttpResponse,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpRequest,akka.NotUsed> |
apply(ServerSettings settings,
akka.event.LoggingAdapter log,
boolean isSecureConnection) |
akka.stream.scaladsl.BidiFlow<HttpResponse,ResponseRenderingContext,ParserOutput.RequestOutput,ParserOutput.RequestOutput,akka.NotUsed> |
controller(ServerSettings settings,
akka.event.LoggingAdapter log) |
akka.stream.scaladsl.Flow<akka.stream.TLSProtocol.SessionBytes,ParserOutput.RequestOutput,akka.NotUsed> |
parsing(ServerSettings settings,
akka.event.LoggingAdapter log,
boolean isSecureConnection) |
akka.stream.scaladsl.BidiFlow<ResponseRenderingContext,ResponseRenderingOutput,akka.stream.TLSProtocol.SessionBytes,ParserOutput.RequestOutput,akka.NotUsed> |
parsingRendering(ServerSettings settings,
akka.event.LoggingAdapter log,
boolean isSecureConnection) |
akka.stream.scaladsl.Flow<ResponseRenderingContext,ResponseRenderingOutput,akka.NotUsed> |
rendering(ServerSettings settings,
akka.event.LoggingAdapter log) |
akka.stream.scaladsl.BidiFlow<HttpResponse,HttpResponse,ParserOutput.RequestOutput,HttpRequest,akka.NotUsed> |
requestPreparation(ServerSettings settings) |
akka.stream.scaladsl.BidiFlow<HttpResponse,HttpResponse,HttpRequest,HttpRequest,akka.NotUsed> |
requestTimeoutSupport(scala.concurrent.duration.Duration timeout,
akka.event.LoggingAdapter log) |
akka.stream.scaladsl.BidiFlow<akka.util.ByteString,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,akka.stream.TLSProtocol.SessionBytes,akka.NotUsed> |
tlsSupport() |
akka.stream.scaladsl.BidiFlow<HttpResponse,HttpResponse,HttpRequest,HttpRequest,akka.NotUsed> |
userHandlerGuard(int pipeliningLimit)
Ensures that the user handler
- produces exactly one response per request
- has not more than
pipeliningLimit responses outstanding |
akka.stream.scaladsl.BidiFlow<ResponseRenderingOutput,akka.util.ByteString,akka.stream.TLSProtocol.SessionBytes,akka.stream.TLSProtocol.SessionBytes,akka.NotUsed> |
websocketSupport(ServerSettings settings,
akka.event.LoggingAdapter log) |
public static final HttpServerBluePrint$ MODULE$
public akka.stream.scaladsl.BidiFlow<HttpResponse,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpRequest,akka.NotUsed> apply(ServerSettings settings, akka.event.LoggingAdapter log, boolean isSecureConnection)
public akka.stream.scaladsl.BidiFlow<akka.util.ByteString,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,akka.stream.TLSProtocol.SessionBytes,akka.NotUsed> tlsSupport()
public akka.stream.scaladsl.BidiFlow<ResponseRenderingOutput,akka.util.ByteString,akka.stream.TLSProtocol.SessionBytes,akka.stream.TLSProtocol.SessionBytes,akka.NotUsed> websocketSupport(ServerSettings settings, akka.event.LoggingAdapter log)
public akka.stream.scaladsl.BidiFlow<ResponseRenderingContext,ResponseRenderingOutput,akka.stream.TLSProtocol.SessionBytes,ParserOutput.RequestOutput,akka.NotUsed> parsingRendering(ServerSettings settings, akka.event.LoggingAdapter log, boolean isSecureConnection)
public akka.stream.scaladsl.BidiFlow<HttpResponse,ResponseRenderingContext,ParserOutput.RequestOutput,ParserOutput.RequestOutput,akka.NotUsed> controller(ServerSettings settings, akka.event.LoggingAdapter log)
public akka.stream.scaladsl.BidiFlow<HttpResponse,HttpResponse,ParserOutput.RequestOutput,HttpRequest,akka.NotUsed> requestPreparation(ServerSettings settings)
public akka.stream.scaladsl.BidiFlow<HttpResponse,HttpResponse,HttpRequest,HttpRequest,akka.NotUsed> requestTimeoutSupport(scala.concurrent.duration.Duration timeout, akka.event.LoggingAdapter log)
public akka.stream.scaladsl.Flow<akka.stream.TLSProtocol.SessionBytes,ParserOutput.RequestOutput,akka.NotUsed> parsing(ServerSettings settings, akka.event.LoggingAdapter log, boolean isSecureConnection)
public akka.stream.scaladsl.Flow<ResponseRenderingContext,ResponseRenderingOutput,akka.NotUsed> rendering(ServerSettings settings, akka.event.LoggingAdapter log)
public akka.stream.scaladsl.BidiFlow<HttpResponse,HttpResponse,HttpRequest,HttpRequest,akka.NotUsed> userHandlerGuard(int pipeliningLimit)
pipeliningLimit
responses outstandingpipeliningLimit
- (undocumented)