public final class GracefulTerminatorStage extends akka.stream.stage.GraphStageWithMaterializedValue<akka.stream.BidiShape<HttpResponse,HttpResponse,HttpRequest,HttpRequest>,ServerTerminator>
Http.ServerBinding
.
Stage shape diagram:
+---+
fromNet Request -> | G | -> toUser Request
| T |
toNet Response <- | S | <- fromUser Response
+---+
Modifier and Type | Class and Description |
---|---|
class |
GracefulTerminatorStage.ConnectionTerminator |
Constructor and Description |
---|
GracefulTerminatorStage(ServerSettings settings) |
Modifier and Type | Method and 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() |
addAttributes, async, async, async, createLogicAndMaterializedValue, initialAttributes, named, traversalBuilder, withAttributes
public GracefulTerminatorStage(ServerSettings settings)
public static akka.stream.scaladsl.BidiFlow<HttpResponse,HttpResponse,HttpRequest,HttpRequest,ServerTerminator> apply(akka.actor.ActorSystem system, ServerSettings serverSettings)
public akka.stream.Inlet<HttpRequest> fromNet()
public akka.stream.Outlet<HttpRequest> toUser()
public akka.stream.Inlet<HttpResponse> fromUser()
public akka.stream.Outlet<HttpResponse> toNet()
public akka.stream.BidiShape<HttpResponse,HttpResponse,HttpRequest,HttpRequest> shape()
public final java.lang.String TerminationDeadlineTimerKey()
public scala.Tuple2<akka.stream.stage.GraphStageLogic,ServerTerminator> createLogicAndMaterializedValue(akka.stream.Attributes inheritedAttributes)
createLogicAndMaterializedValue
in class akka.stream.stage.GraphStageWithMaterializedValue<akka.stream.BidiShape<HttpResponse,HttpResponse,HttpRequest,HttpRequest>,ServerTerminator>