public static final class SlotState.WaitingForResponseEntitySubscription extends SlotState.ConnectedState implements SlotState.BusyWithResultAlreadyDispatched, scala.Product, scala.Serializable
SlotState.BusyState, SlotState.BusyWithResultAlreadyDispatched, SlotState.ConnectedState, SlotState.Connecting, SlotState.Connecting$, SlotState.Idle$, SlotState.IdleState, SlotState.PreConnecting$, SlotState.Unconnected$, SlotState.WaitingForEndOfRequestEntity, SlotState.WaitingForEndOfRequestEntity$, SlotState.WaitingForEndOfResponseEntity, SlotState.WaitingForEndOfResponseEntity$, SlotState.WaitingForResponse, SlotState.WaitingForResponse$, SlotState.WaitingForResponseDispatch, SlotState.WaitingForResponseDispatch$, SlotState.WaitingForResponseEntitySubscription, SlotState.WaitingForResponseEntitySubscription$, SlotState.WithRequestDispatching
Constructor and Description |
---|
WaitingForResponseEntitySubscription(PoolFlow.RequestContext ongoingRequest,
HttpResponse ongoingResponse,
scala.concurrent.duration.Duration stateTimeout) |
Modifier and Type | Method and Description |
---|---|
PoolFlow.RequestContext |
ongoingRequest() |
HttpResponse |
ongoingResponse() |
SlotState |
onResponseEntitySubscribed(SlotContext ctx) |
SlotState |
onTimeout(SlotContext ctx) |
scala.concurrent.duration.Duration |
stateTimeout()
A slot can define a timeout for that state after which onTimeout will be called.
|
isConnected
illegalState, isIdle, name, onConnectionAttemptFailed, onConnectionAttemptSucceeded, onConnectionCompleted, onConnectionFailed, onNewRequest, onPreConnect, onRequestEntityCompleted, onRequestEntityFailed, onResponseDispatchable, onResponseEntityCompleted, onResponseEntityFailed, onResponseReceived, onShutdown
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onConnectionCompleted, onConnectionFailed, onResponseEntityFailed
failOngoingRequest, isIdle, onConnectionAttemptFailed, onRequestEntityFailed, onShutdown
public WaitingForResponseEntitySubscription(PoolFlow.RequestContext ongoingRequest, HttpResponse ongoingResponse, scala.concurrent.duration.Duration stateTimeout)
public PoolFlow.RequestContext ongoingRequest()
ongoingRequest
in interface SlotState.BusyState
public HttpResponse ongoingResponse()
public scala.concurrent.duration.Duration stateTimeout()
SlotState
stateTimeout
in class SlotState
public SlotState onResponseEntitySubscribed(SlotContext ctx)
onResponseEntitySubscribed
in class SlotState
public SlotState onTimeout(SlotContext ctx)