public static final class SlotState.WaitingForResponseDispatch 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 |
---|
WaitingForResponseDispatch(PoolFlow.RequestContext ongoingRequest,
scala.util.Try<HttpResponse> result,
boolean waitingForEndOfRequestEntity) |
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
|
SlotState |
onResponseDispatchable(SlotContext ctx)
Called when the response out port is ready to receive a further response (successful or failed)
|
scala.util.Try<HttpResponse> |
result() |
boolean |
waitingForEndOfRequestEntity() |
isConnected, onNewConnectionEmbargo
idle, illegalState, isIdle, name, onConnectionAttemptFailed, onConnectionAttemptSucceeded, onConnectionCompleted, onConnectionFailed, onNewRequest, onPreConnect, onRequestDispatched, onRequestEntityFailed, onResponseEntityCompleted, onResponseEntityFailed, onResponseEntitySubscribed, onResponseReceived, onShutdown, onTimeout, stateTimeout
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onConnectionCompleted, onConnectionFailed, onRequestEntityFailed, onResponseEntityFailed
failOngoingRequest, isIdle, onConnectionAttemptFailed, onShutdown
public WaitingForResponseDispatch(PoolFlow.RequestContext ongoingRequest, scala.util.Try<HttpResponse> result, boolean waitingForEndOfRequestEntity)
public PoolFlow.RequestContext ongoingRequest()
ongoingRequest
in interface SlotState.BusyState
public scala.util.Try<HttpResponse> result()
public boolean waitingForEndOfRequestEntity()
waitingForEndOfRequestEntity
in interface SlotState.BusyState
public SlotState onRequestEntityCompleted(SlotContext ctx)
SlotState
onRequestEntityCompleted
in class SlotState
public SlotState onResponseDispatchable(SlotContext ctx)
onResponseDispatchable
in class SlotState