Class FrameOutHandler
java.lang.Object
org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<S,org.apache.pekko.NotUsed>
org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<Object,FrameStart>>
org.apache.pekko.http.impl.engine.ws.FrameOutHandler
- All Implemented Interfaces:
org.apache.pekko.stream.Graph<org.apache.pekko.stream.FlowShape<Object,
FrameStart>, org.apache.pekko.NotUsed>
public class FrameOutHandler
extends org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<Object,FrameStart>>
Implements the transport connection close handling at the end of the pipeline.
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
ConstructorsConstructorDescriptionFrameOutHandler
(boolean serverSide, scala.concurrent.duration.FiniteDuration _closeTimeout, org.apache.pekko.event.LoggingAdapter log) -
Method Summary
Modifier and TypeMethodDescriptionstatic org.apache.pekko.stream.scaladsl.Flow<Object,
FrameStart, org.apache.pekko.NotUsed> create
(boolean serverSide, scala.concurrent.duration.FiniteDuration closeTimeout, org.apache.pekko.event.LoggingAdapter log) org.apache.pekko.stream.stage.GraphStageLogic
createLogic
(org.apache.pekko.stream.Attributes inheritedAttributes) org.apache.pekko.stream.Inlet<Object>
in()
org.apache.pekko.stream.Outlet<FrameStart>
out()
org.apache.pekko.stream.FlowShape<Object,
FrameStart> shape()
Methods inherited from class org.apache.pekko.stream.stage.GraphStage
createLogicAndMaterializedValue
Methods inherited from class org.apache.pekko.stream.stage.GraphStageWithMaterializedValue
addAttributes, async, async, async, createLogicAndMaterializedValue, getAttributes, initialAttributes, named, traversalBuilder, withAttributes
-
Constructor Details
-
FrameOutHandler
public FrameOutHandler(boolean serverSide, scala.concurrent.duration.FiniteDuration _closeTimeout, org.apache.pekko.event.LoggingAdapter log)
-
-
Method Details
-
create
public static org.apache.pekko.stream.scaladsl.Flow<Object,FrameStart, createorg.apache.pekko.NotUsed> (boolean serverSide, scala.concurrent.duration.FiniteDuration closeTimeout, org.apache.pekko.event.LoggingAdapter log) -
in
-
out
-
shape
-
createLogic
public org.apache.pekko.stream.stage.GraphStageLogic createLogic(org.apache.pekko.stream.Attributes inheritedAttributes) - Specified by:
createLogic
in classorg.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<Object,
FrameStart>>
-