Class SlotState.Embargoed
- java.lang.Object
-
- akka.http.impl.engine.client.pool.SlotState
-
- akka.http.impl.engine.client.pool.SlotState.Embargoed
-
- All Implemented Interfaces:
java.io.Serializable
,scala.Equals
,scala.Product
- Enclosing class:
- SlotState
public static class SlotState.Embargoed extends SlotState implements scala.Product, java.io.Serializable
- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class akka.http.impl.engine.client.pool.SlotState
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 Summary
Constructors Constructor Description Embargoed(scala.concurrent.duration.FiniteDuration embargoDuration)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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.-
Methods inherited from class akka.http.impl.engine.client.pool.SlotState
idle, illegalState, name, onConnectionAttemptFailed, onConnectionAttemptSucceeded, onConnectionCompleted, onConnectionFailed, onNewRequest, onPreConnect, onRequestDispatched, onRequestEntityCompleted, onRequestEntityFailed, onResponseDispatchable, onResponseEntityCompleted, onResponseEntityFailed, onResponseEntitySubscribed, onResponseReceived, onShutdown
-
-
-
-
Method Detail
-
embargoDuration
public scala.concurrent.duration.FiniteDuration embargoDuration()
-
isConnected
public boolean isConnected()
- Specified by:
isConnected
in classSlotState
-
stateTimeout
public scala.concurrent.duration.Duration stateTimeout()
Description copied from class:SlotState
A slot can define a timeout for that state after which onTimeout will be called.- Overrides:
stateTimeout
in classSlotState
-
onTimeout
public SlotState onTimeout(SlotContext ctx)
-
onNewConnectionEmbargo
public SlotState onNewConnectionEmbargo(SlotContext ctx, scala.concurrent.duration.FiniteDuration embargoDuration)
- Overrides:
onNewConnectionEmbargo
in classSlotState
-
-