akka.http.impl.engine.ws

Class FrameOutHandler

java.lang.Object

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

akka.stream.stage.GraphStage<akka.stream.FlowShape<java.lang.Object,FrameStart>>

akka.http.impl.engine.ws.FrameOutHandler

All Implemented Interfaces:

akka.stream.Graph<akka.stream.FlowShape<java.lang.Object,FrameStart>,akka.NotUsed>

public class FrameOutHandler
extends akka.stream.stage.GraphStage<akka.stream.FlowShape<java.lang.Object,FrameStart>>

Implements the transport connection close handling at the end of the pipeline.

INTERNAL API

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
static akka.stream.scaladsl.Flow<java.lang.Object,FrameStart,akka.NotUsed>	create(boolean serverSide, scala.concurrent.duration.FiniteDuration closeTimeout, akka.event.LoggingAdapter log)
akka.stream.stage.GraphStageLogic	createLogic(akka.stream.Attributes inheritedAttributes)
akka.stream.Inlet<java.lang.Object>	in()
akka.stream.Outlet<FrameStart>	out()
akka.stream.FlowShape<java.lang.Object,FrameStart>	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

FrameOutHandler

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

Method Detail

create

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

in

public akka.stream.Inlet<java.lang.Object> in()

out

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

shape

public akka.stream.FlowShape<java.lang.Object,FrameStart> shape()

createLogic

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

Specified by:

createLogic in class akka.stream.stage.GraphStage<akka.stream.FlowShape<java.lang.Object,FrameStart>>