public static final class SlotState.Idle extends SlotState.ConnectedState implements SlotState.IdleState, 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 |
---|
Idle(scala.concurrent.duration.Duration keepAliveTimeout) |
Modifier and Type | Method and Description |
---|---|
scala.concurrent.duration.Duration |
keepAliveTimeout() |
SlotState |
onConnectionCompleted(SlotContext ctx) |
SlotState |
onConnectionFailed(SlotContext ctx,
java.lang.Throwable cause) |
SlotState |
onNewRequest(SlotContext ctx,
PoolFlow.RequestContext requestContext) |
SlotState |
onTimeout(SlotContext ctx) |
scala.concurrent.duration.Duration |
stateTimeout()
A slot can define a timeout for that state after which onTimeout will be called.
|
isConnected, onNewConnectionEmbargo
idle, illegalState, isIdle, name, onConnectionAttemptFailed, onConnectionAttemptSucceeded, onPreConnect, onRequestDispatched, onRequestEntityCompleted, onRequestEntityFailed, onResponseDispatchable, onResponseEntityCompleted, onResponseEntityFailed, onResponseEntitySubscribed, onResponseReceived, onShutdown
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isIdle
public scala.concurrent.duration.Duration keepAliveTimeout()
public scala.concurrent.duration.Duration stateTimeout()
SlotState
stateTimeout
in class SlotState
public SlotState onNewRequest(SlotContext ctx, PoolFlow.RequestContext requestContext)
onNewRequest
in class SlotState
public SlotState onTimeout(SlotContext ctx)
public SlotState onConnectionCompleted(SlotContext ctx)
onConnectionCompleted
in class SlotState
public SlotState onConnectionFailed(SlotContext ctx, java.lang.Throwable cause)
onConnectionFailed
in class SlotState