public static final class SlotState.WaitingForResponseEntitySubscription extends SlotState.ConnectedState implements SlotState.BusyWithResultAlreadyDetermined, scala.Product, java.io.Serializable
SlotState.BusyState, SlotState.BusyWithResultAlreadyDetermined, SlotState.ConnectedState, SlotState.Connecting, SlotState.Connecting$, SlotState.Embargoed, SlotState.Embargoed$, SlotState.Failed, SlotState.Failed$, SlotState.Idle, SlotState.Idle$, SlotState.IdleState, SlotState.OutOfEmbargo$, SlotState.PreConnecting$, SlotState.PushingRequestToConnection, SlotState.PushingRequestToConnection$, SlotState.ShouldCloseConnectionState, SlotState.ToBeClosed$, SlotState.Unconnected$, SlotState.UnconnectedState, SlotState.WaitingForEndOfRequestEntity$, SlotState.WaitingForEndOfResponseEntity, SlotState.WaitingForEndOfResponseEntity$, SlotState.WaitingForResponse, SlotState.WaitingForResponse$, SlotState.WaitingForResponseDispatch, SlotState.WaitingForResponseDispatch$, SlotState.WaitingForResponseEntitySubscription, SlotState.WaitingForResponseEntitySubscription$
Constructor and Description |
---|
WaitingForResponseEntitySubscription(PoolFlow.RequestContext ongoingRequest,
HttpResponse ongoingResponse,
scala.concurrent.duration.Duration stateTimeout,
boolean waitingForEndOfRequestEntity) |
Modifier and Type | Method and Description |
---|---|
PoolFlow.RequestContext |
ongoingRequest() |
HttpResponse |
ongoingResponse() |
SlotState |
onRequestEntityCompleted(SlotContext ctx)
Will be called either immediately if the request entity is strict or otherwise later
|
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.
|
boolean |
waitingForEndOfRequestEntity() |
isConnected, onNewConnectionEmbargo
idle, illegalState, isIdle, name, onConnectionAttemptFailed, onConnectionAttemptSucceeded, onConnectionCompleted, onConnectionFailed, onNewRequest, onPreConnect, onRequestDispatched, onRequestEntityFailed, onResponseDispatchable, onResponseEntityCompleted, onResponseEntityFailed, onResponseReceived, onShutdown
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onConnectionCompleted, onConnectionFailed, onRequestEntityFailed, onResponseEntityFailed
failOngoingRequest, isIdle, onConnectionAttemptFailed, onShutdown
public WaitingForResponseEntitySubscription(PoolFlow.RequestContext ongoingRequest, HttpResponse ongoingResponse, scala.concurrent.duration.Duration stateTimeout, boolean waitingForEndOfRequestEntity)
public PoolFlow.RequestContext ongoingRequest()
ongoingRequest
in interface SlotState.BusyState
public HttpResponse ongoingResponse()
public scala.concurrent.duration.Duration stateTimeout()
SlotState
stateTimeout
in class SlotState
public boolean waitingForEndOfRequestEntity()
waitingForEndOfRequestEntity
in interface SlotState.BusyState
public SlotState onRequestEntityCompleted(SlotContext ctx)
SlotState
onRequestEntityCompleted
in class SlotState
public SlotState onResponseEntitySubscribed(SlotContext ctx)
onResponseEntitySubscribed
in class SlotState
public SlotState onTimeout(SlotContext ctx)