Class RequestErrorFlow
java.lang.Object
org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<S,org.apache.pekko.NotUsed>
org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.BidiShape<HttpResponse,HttpResponse,RequestParsing.ParseRequestResult,HttpRequest>>
org.apache.pekko.http.impl.engine.http2.RequestErrorFlow
- All Implemented Interfaces:
org.apache.pekko.stream.Graph<org.apache.pekko.stream.BidiShape<HttpResponse,HttpResponse, RequestParsing.ParseRequestResult, HttpRequest>, org.apache.pekko.NotUsed>
public final class RequestErrorFlow
extends org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.BidiShape<HttpResponse,HttpResponse,RequestParsing.ParseRequestResult,HttpRequest>>
INTERNAL API
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.apache.pekko.stream.Graph
org.apache.pekko.stream.Graph.GraphMapMatVal<S extends org.apache.pekko.stream.Shape,M extends Object> -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic org.apache.pekko.stream.scaladsl.BidiFlow<HttpResponse,HttpResponse, RequestParsing.ParseRequestResult, HttpRequest, org.apache.pekko.NotUsed> apply()org.apache.pekko.stream.stage.GraphStageLogiccreateLogic(org.apache.pekko.stream.Attributes inheritedAttributes) org.apache.pekko.stream.Inlet<RequestParsing.ParseRequestResult>org.apache.pekko.stream.Outlet<HttpRequest>org.apache.pekko.stream.Inlet<HttpResponse>org.apache.pekko.stream.Outlet<HttpResponse>org.apache.pekko.stream.BidiShape<HttpResponse,HttpResponse, RequestParsing.ParseRequestResult, HttpRequest> shape()Methods inherited from class org.apache.pekko.stream.stage.GraphStage
createLogicAndMaterializedValueMethods inherited from class org.apache.pekko.stream.stage.GraphStageWithMaterializedValue
addAttributes, async, async, async, createLogicAndMaterializedValue, getAttributes, initialAttributes, named, traversalBuilder, withAttributes
-
Constructor Details
-
RequestErrorFlow
public RequestErrorFlow()
-
-
Method Details
-
apply
public static org.apache.pekko.stream.scaladsl.BidiFlow<HttpResponse,HttpResponse, apply()RequestParsing.ParseRequestResult, HttpRequest, org.apache.pekko.NotUsed> -
requestIn
-
requestOut
-
responseIn
-
responseOut
-
shape
public org.apache.pekko.stream.BidiShape<HttpResponse,HttpResponse, shape()RequestParsing.ParseRequestResult, HttpRequest> -
createLogic
public org.apache.pekko.stream.stage.GraphStageLogic createLogic(org.apache.pekko.stream.Attributes inheritedAttributes) - Specified by:
createLogicin classorg.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.BidiShape<HttpResponse,HttpResponse, RequestParsing.ParseRequestResult, HttpRequest>>
-