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 and Description
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>

Constructor Summary

Constructors

Constructor and Description
GracefulTerminatorStage(ServerSettings settings)

Method Summary

Modifier and Type	Method and 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()
java.lang.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

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

$init$, GraphMapMatVal, mapMaterializedValue

Constructor Detail

GracefulTerminatorStage

public GracefulTerminatorStage(ServerSettings settings)

Method Detail

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 java.lang.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>