org.apache.pekko.http.impl.engine.ws

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<java.lang.Object,FrameStart>>

org.apache.pekko.http.impl.engine.ws.FrameOutHandler

All Implemented Interfaces:

org.apache.pekko.stream.Graph<org.apache.pekko.stream.FlowShape<java.lang.Object,FrameStart>,org.apache.pekko.NotUsed>

public class FrameOutHandler
extends org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<java.lang.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>

Constructor Summary

Constructors

Constructor and Description
FrameOutHandler(boolean serverSide, scala.concurrent.duration.FiniteDuration _closeTimeout, org.apache.pekko.event.LoggingAdapter log)

Method Summary

Modifier and Type	Method and Description
static org.apache.pekko.stream.scaladsl.Flow<java.lang.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<java.lang.Object>	in()
org.apache.pekko.stream.Outlet<FrameStart>	out()
org.apache.pekko.stream.FlowShape<java.lang.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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.pekko.stream.Graph

$init$, GraphMapMatVal, mapMaterializedValue

Constructor Detail

FrameOutHandler

public FrameOutHandler(boolean serverSide,
                       scala.concurrent.duration.FiniteDuration _closeTimeout,
                       org.apache.pekko.event.LoggingAdapter log)

Method Detail

create

public static org.apache.pekko.stream.scaladsl.Flow<java.lang.Object,FrameStart,org.apache.pekko.NotUsed> create(boolean serverSide,
                                                                                                                 scala.concurrent.duration.FiniteDuration closeTimeout,
                                                                                                                 org.apache.pekko.event.LoggingAdapter log)

in

public org.apache.pekko.stream.Inlet<java.lang.Object> in()

out

public org.apache.pekko.stream.Outlet<FrameStart> out()

shape

public org.apache.pekko.stream.FlowShape<java.lang.Object,FrameStart> shape()

createLogic

public org.apache.pekko.stream.stage.GraphStageLogic createLogic(org.apache.pekko.stream.Attributes inheritedAttributes)

Specified by:

createLogic in class org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<java.lang.Object,FrameStart>>