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 SummaryNested classes/interfaces inherited from interface org.apache.pekko.stream.Graphorg.apache.pekko.stream.Graph.GraphMapMatVal<S extends org.apache.pekko.stream.Shape,M extends Object> 
- 
Constructor SummaryConstructorsConstructorDescriptionFrameOutHandler(boolean serverSide, scala.concurrent.duration.FiniteDuration _closeTimeout, org.apache.pekko.event.LoggingAdapter log) 
- 
Method SummaryModifier 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.GraphStageLogiccreateLogic(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.GraphStagecreateLogicAndMaterializedValueMethods inherited from class org.apache.pekko.stream.stage.GraphStageWithMaterializedValueaddAttributes, async, async, async, createLogicAndMaterializedValue, getAttributes, initialAttributes, named, traversalBuilder, withAttributes
- 
Constructor Details- 
FrameOutHandlerpublic FrameOutHandler(boolean serverSide, scala.concurrent.duration.FiniteDuration _closeTimeout, org.apache.pekko.event.LoggingAdapter log) 
 
- 
- 
Method Details- 
createpublic 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
- 
createLogicpublic org.apache.pekko.stream.stage.GraphStageLogic createLogic(org.apache.pekko.stream.Attributes inheritedAttributes) - Specified by:
- createLogicin class- org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<Object,- FrameStart>> 
 
 
-