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