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