Package akka.http.impl.engine.server

Class GracefulTerminatorStage

java.lang.Object

akka.stream.stage.GraphStageWithMaterializedValue<akka.stream.BidiShape<HttpResponse,HttpResponse,HttpRequest,HttpRequest>,ServerTerminator>

akka.http.impl.engine.server.GracefulTerminatorStage

All Implemented Interfaces:

akka.stream.Graph<akka.stream.BidiShape<HttpResponse,HttpResponse,HttpRequest,HttpRequest>,ServerTerminator>

public final class GracefulTerminatorStage
extends akka.stream.stage.GraphStageWithMaterializedValue<akka.stream.BidiShape<HttpResponse,HttpResponse,HttpRequest,HttpRequest>,ServerTerminator>

INTERNAL API: See detailed docs termination process on Http.ServerBinding.

Stage shape diagram:

                      +---+
 fromNet Request   -> | G | -> toUser Request
                      | T |
 toNet   Response  <- | S | <- fromUser Response
                      +---+
 

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	GracefulTerminatorStage.ConnectionTerminator

Nested classes/interfaces inherited from interface akka.stream.Graph

akka.stream.Graph.GraphMapMatVal<S extends akka.stream.Shape,M extends java.lang.Object>

Constructor Summary

Constructors

Constructor	Description
GracefulTerminatorStage(ServerSettings settings)

Method Summary

Modifier and Type	Method	Description
static akka.stream.scaladsl.BidiFlow<HttpResponse,HttpResponse,HttpRequest,HttpRequest,ServerTerminator>	apply(akka.actor.ActorSystem system, ServerSettings serverSettings)
scala.Tuple2<akka.stream.stage.GraphStageLogic,ServerTerminator>	createLogicAndMaterializedValue(akka.stream.Attributes inheritedAttributes)
akka.stream.Inlet<HttpRequest>	fromNet()
akka.stream.Inlet<HttpResponse>	fromUser()
akka.stream.BidiShape<HttpResponse,HttpResponse,HttpRequest,HttpRequest>	shape()
java.lang.String	TerminationDeadlineTimerKey()
akka.stream.Outlet<HttpResponse>	toNet()
akka.stream.Outlet<HttpRequest>	toUser()

Methods inherited from class akka.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

Constructor Detail

GracefulTerminatorStage

public GracefulTerminatorStage(ServerSettings settings)

Method Detail

apply

public static akka.stream.scaladsl.BidiFlow<HttpResponse,HttpResponse,HttpRequest,HttpRequest,ServerTerminator> apply(akka.actor.ActorSystem system,
                                                                                                                                              ServerSettings serverSettings)

fromNet

public akka.stream.Inlet<HttpRequest> fromNet()

toUser

public akka.stream.Outlet<HttpRequest> toUser()

fromUser

public akka.stream.Inlet<HttpResponse> fromUser()

toNet

public akka.stream.Outlet<HttpResponse> toNet()

shape

public akka.stream.BidiShape<HttpResponse,HttpResponse,HttpRequest,HttpRequest> shape()

TerminationDeadlineTimerKey

public final java.lang.String TerminationDeadlineTimerKey()

createLogicAndMaterializedValue

public scala.Tuple2<akka.stream.stage.GraphStageLogic,ServerTerminator> createLogicAndMaterializedValue(akka.stream.Attributes inheritedAttributes)

Specified by:

createLogicAndMaterializedValue in class akka.stream.stage.GraphStageWithMaterializedValue<akka.stream.BidiShape<HttpResponse,HttpResponse,HttpRequest,HttpRequest>,ServerTerminator>