Package org.apache.pekko.http.impl.engine.server

Class GracefulTerminatorStage

java.lang.Object

org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<org.apache.pekko.stream.BidiShape<HttpResponse,HttpResponse,HttpRequest,HttpRequest>,ServerTerminator>

org.apache.pekko.http.impl.engine.server.GracefulTerminatorStage

All Implemented Interfaces:

org.apache.pekko.stream.Graph<org.apache.pekko.stream.BidiShape<HttpResponse,HttpResponse,HttpRequest,HttpRequest>,ServerTerminator>

public final class GracefulTerminatorStage
extends org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<org.apache.pekko.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
final class	GracefulTerminatorStage.ConnectionTerminator

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

Constructors

Constructor	Description
GracefulTerminatorStage(ServerSettings settings)

Method Summary

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

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

Constructor Details

GracefulTerminatorStage

public GracefulTerminatorStage(ServerSettings settings)

Method Details

apply

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

fromNet

public org.apache.pekko.stream.Inlet<HttpRequest> fromNet()

toUser

public org.apache.pekko.stream.Outlet<HttpRequest> toUser()

fromUser

public org.apache.pekko.stream.Inlet<HttpResponse> fromUser()

toNet

public org.apache.pekko.stream.Outlet<HttpResponse> toNet()

shape

public org.apache.pekko.stream.BidiShape<HttpResponse,HttpResponse,HttpRequest,HttpRequest> shape()

TerminationDeadlineTimerKey

public final String TerminationDeadlineTimerKey()

createLogicAndMaterializedValue

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

Specified by:

createLogicAndMaterializedValue in class org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<org.apache.pekko.stream.BidiShape<HttpResponse,HttpResponse,HttpRequest,HttpRequest>,ServerTerminator>