public static final class SlotState.WaitingForEndOfRequestEntity extends SlotState.ConnectedState implements SlotState.BusyState, 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 |
---|
WaitingForEndOfRequestEntity(PoolFlow.RequestContext ongoingRequest) |
Modifier and Type | Method and Description |
---|---|
PoolFlow.RequestContext |
ongoingRequest() |
SlotState |
onRequestEntityCompleted(SlotContext ctx)
Will be called either immediately if the request entity is strict or otherwise later
|
isConnected
illegalState, isIdle, name, onConnectionAttemptFailed, onConnectionAttemptSucceeded, onConnectionCompleted, onConnectionFailed, onNewRequest, onPreConnect, onRequestEntityFailed, onResponseDispatchable, onResponseEntityCompleted, onResponseEntityFailed, onResponseEntitySubscribed, onResponseReceived, onShutdown, onTimeout, stateTimeout
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
failOngoingRequest, isIdle, onConnectionAttemptFailed, onConnectionCompleted, onConnectionFailed, onRequestEntityFailed, onShutdown
public WaitingForEndOfRequestEntity(PoolFlow.RequestContext ongoingRequest)
public PoolFlow.RequestContext ongoingRequest()
ongoingRequest
in interface SlotState.BusyState
public SlotState onRequestEntityCompleted(SlotContext ctx)
SlotState
onRequestEntityCompleted
in class SlotState