Class SlotState.ConnectedState
- java.lang.Object
-
- akka.http.impl.engine.client.pool.SlotState
-
- akka.http.impl.engine.client.pool.SlotState.ConnectedState
-
- All Implemented Interfaces:
scala.Equals
,scala.Product
- Direct Known Subclasses:
SlotState.Connecting
,SlotState.Idle
,SlotState.PreConnecting$
,SlotState.PushingRequestToConnection
,SlotState.WaitingForEndOfRequestEntity$
,SlotState.WaitingForEndOfResponseEntity
,SlotState.WaitingForResponse
,SlotState.WaitingForResponseDispatch
,SlotState.WaitingForResponseEntitySubscription
- Enclosing class:
- SlotState
public abstract static class SlotState.ConnectedState extends SlotState
-
-
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 ConnectedState()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
isConnected()
SlotState
onNewConnectionEmbargo(SlotContext ctx, scala.concurrent.duration.FiniteDuration embargoDuration)
-
Methods inherited from class akka.http.impl.engine.client.pool.SlotState
idle, illegalState, isIdle, name, onConnectionAttemptFailed, onConnectionAttemptSucceeded, onConnectionCompleted, onConnectionFailed, onNewRequest, onPreConnect, onRequestDispatched, onRequestEntityCompleted, onRequestEntityFailed, onResponseDispatchable, onResponseEntityCompleted, onResponseEntityFailed, onResponseEntitySubscribed, onResponseReceived, onShutdown, onTimeout, stateTimeout
-
-
-
-
Method Detail
-
isConnected
public boolean isConnected()
- Specified by:
isConnected
in classSlotState
-
onNewConnectionEmbargo
public SlotState onNewConnectionEmbargo(SlotContext ctx, scala.concurrent.duration.FiniteDuration embargoDuration)
- Overrides:
onNewConnectionEmbargo
in classSlotState
-
-