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.FiniteDurationembargoDuration()booleanisConnected()booleanisIdle()SlotStateonNewConnectionEmbargo(SlotContext ctx, scala.concurrent.duration.FiniteDuration embargoDuration)SlotStateonTimeout(SlotContext ctx)scala.concurrent.duration.DurationstateTimeout()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:
isConnectedin classSlotState
-
stateTimeout
public scala.concurrent.duration.Duration stateTimeout()
Description copied from class:SlotStateA slot can define a timeout for that state after which onTimeout will be called.- Overrides:
stateTimeoutin classSlotState
-
onTimeout
public SlotState onTimeout(SlotContext ctx)
-
onNewConnectionEmbargo
public SlotState onNewConnectionEmbargo(SlotContext ctx, scala.concurrent.duration.FiniteDuration embargoDuration)
- Overrides:
onNewConnectionEmbargoin classSlotState
-
-