akka.http.impl.engine.server

Class HttpServerBluePrint.PrepareRequests

java.lang.Object

akka.stream.stage.GraphStageWithMaterializedValue<S,akka.NotUsed>

akka.stream.stage.GraphStage<akka.stream.FlowShape<ParserOutput.RequestOutput,HttpRequest>>

akka.http.impl.engine.server.HttpServerBluePrint.PrepareRequests

All Implemented Interfaces:

akka.stream.Graph<akka.stream.FlowShape<ParserOutput.RequestOutput,HttpRequest>,akka.NotUsed>

Enclosing class:

HttpServerBluePrint

public static final class HttpServerBluePrint.PrepareRequests
extends akka.stream.stage.GraphStage<akka.stream.FlowShape<ParserOutput.RequestOutput,HttpRequest>>

Two state stage, either transforms an incoming RequestOutput into a HttpRequest with strict entity and then pushes that (the "idle" inHandler) or creates a HttpRequest with a streamed entity and switch to a state which will push incoming chunks into the streaming entity until end of request is reached (the StreamedEntityCreator case in create entity).

Constructor Summary

Constructors

Constructor and Description
PrepareRequests(ServerSettings settings)

Method Summary

Modifier and Type	Method and Description
akka.stream.stage.GraphStageLogic	createLogic(akka.stream.Attributes inheritedAttributes)
akka.stream.Inlet<ParserOutput.RequestOutput>	in()
akka.stream.Outlet<HttpRequest>	out()
akka.stream.FlowShape<ParserOutput.RequestOutput,HttpRequest>	shape()

Methods inherited from class akka.stream.stage.GraphStage

createLogicAndMaterializedValue

Methods inherited from class akka.stream.stage.GraphStageWithMaterializedValue

addAttributes, async, initialAttributes, module, named, withAttributes

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.stream.Graph

$init$

Constructor Detail

PrepareRequests

public PrepareRequests(ServerSettings settings)

Method Detail

createLogic

public akka.stream.stage.GraphStageLogic createLogic(akka.stream.Attributes inheritedAttributes)

Specified by:

createLogic in class akka.stream.stage.GraphStage<akka.stream.FlowShape<ParserOutput.RequestOutput,HttpRequest>>

in

public akka.stream.Inlet<ParserOutput.RequestOutput> in()

out

public akka.stream.Outlet<HttpRequest> out()

shape

public akka.stream.FlowShape<ParserOutput.RequestOutput,HttpRequest> shape()