Class SlotState
java.lang.Object
akka.http.impl.engine.client.pool.SlotState
- All Implemented Interfaces:
scala.Equals
,scala.Product
- Direct Known Subclasses:
SlotState.ConnectedState
,SlotState.Embargoed
,SlotState.OutOfEmbargo$
,SlotState.ShouldCloseConnectionState
,SlotState.Unconnected$
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic interface
static interface
static class
static final class
static class
static class
static class
static class
static class
static final class
static class
static interface
static class
static class
static final class
static class
static class
static class
static class
static interface
static class
static final class
static class
static final class
static class
static final class
static class
static final class
static class
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionidle
(SlotContext ctx) protected SlotState
illegalState
(SlotContext ctx, String what) abstract boolean
abstract boolean
isIdle()
name()
onConnectionAttemptFailed
(SlotContext ctx, Throwable cause) onConnectionAttemptSucceeded
(SlotContext ctx, Http.OutgoingConnection outgoingConnection) onConnectionFailed
(SlotContext ctx, Throwable cause) onNewConnectionEmbargo
(SlotContext ctx, scala.concurrent.duration.FiniteDuration embargoDuration) onNewRequest
(SlotContext ctx, PoolFlow.RequestContext requestContext) onPreConnect
(SlotContext ctx) Will be called either immediately if the request entity is strict or otherwise lateronRequestEntityFailed
(SlotContext ctx, Throwable cause) Called when the response out port is ready to receive a further response (successful or failed)Will be called either immediately if the response entity is strict or otherwise lateronResponseEntityFailed
(SlotContext ctx, Throwable cause) onResponseReceived
(SlotContext ctx, HttpResponse response) void
onShutdown
(SlotContext ctx) onTimeout
(SlotContext ctx) scala.concurrent.duration.Duration
A slot can define a timeout for that state after which onTimeout will be called.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface scala.Equals
canEqual, equals
Methods inherited from interface scala.Product
productArity, productElement, productElementName, productElementNames, productIterator, productPrefix
-
Constructor Details
-
SlotState
public SlotState()
-
-
Method Details
-
isIdle
public abstract boolean isIdle() -
isConnected
public abstract boolean isConnected() -
idle
-
onPreConnect
-
onConnectionAttemptSucceeded
public SlotState onConnectionAttemptSucceeded(SlotContext ctx, Http.OutgoingConnection outgoingConnection) -
onConnectionAttemptFailed
-
onNewConnectionEmbargo
public SlotState onNewConnectionEmbargo(SlotContext ctx, scala.concurrent.duration.FiniteDuration embargoDuration) -
onNewRequest
-
onRequestDispatched
-
onRequestEntityCompleted
Will be called either immediately if the request entity is strict or otherwise later -
onRequestEntityFailed
-
onResponseReceived
-
onResponseDispatchable
Called when the response out port is ready to receive a further response (successful or failed) -
onResponseEntitySubscribed
-
onResponseEntityCompleted
Will be called either immediately if the response entity is strict or otherwise later -
onResponseEntityFailed
-
onConnectionCompleted
-
onConnectionFailed
-
onTimeout
-
onShutdown
-
stateTimeout
public scala.concurrent.duration.Duration stateTimeout()A slot can define a timeout for that state after which onTimeout will be called. -
illegalState
-
name
-