public static final class SlotState.Connecting extends SlotState.ConnectedState implements SlotState.BusyState, SlotState.WithRequestDispatching, 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 |
---|
Connecting(PoolFlow.RequestContext ongoingRequest) |
Modifier and Type | Method and Description |
---|---|
SlotState |
onConnectionAttemptSucceeded(SlotContext ctx,
Http.OutgoingConnection outgoingConnection) |
PoolFlow.RequestContext |
ongoingRequest() |
isConnected
illegalState, isIdle, name, onConnectionAttemptFailed, onConnectionCompleted, onConnectionFailed, onNewRequest, onPreConnect, onRequestEntityCompleted, 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
dispatchRequestToConnection
public Connecting(PoolFlow.RequestContext ongoingRequest)
public PoolFlow.RequestContext ongoingRequest()
ongoingRequest
in interface SlotState.BusyState
public SlotState onConnectionAttemptSucceeded(SlotContext ctx, Http.OutgoingConnection outgoingConnection)
onConnectionAttemptSucceeded
in class SlotState