Class SlotState.WaitingForResponseEntitySubscription
java.lang.Object
akka.http.impl.engine.client.pool.SlotState
akka.http.impl.engine.client.pool.SlotState.ConnectedState
akka.http.impl.engine.client.pool.SlotState.WaitingForResponseEntitySubscription
- All Implemented Interfaces:
SlotState.BusyState
,SlotState.BusyWithResultAlreadyDetermined
,Serializable
,scala.Equals
,scala.Product
- Enclosing class:
- SlotState
public static final class SlotState.WaitingForResponseEntitySubscription
extends SlotState.ConnectedState
implements SlotState.BusyWithResultAlreadyDetermined, scala.Product, Serializable
- See Also:
-
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
ConstructorDescriptionWaitingForResponseEntitySubscription
(PoolFlow.RequestContext ongoingRequest, HttpResponse ongoingResponse, scala.concurrent.duration.Duration stateTimeout, boolean waitingForEndOfRequestEntity) -
Method Summary
Modifier and TypeMethodDescriptionWill be called either immediately if the request entity is strict or otherwise lateronTimeout
(SlotContext ctx) scala.concurrent.duration.Duration
A slot can define a timeout for that state after which onTimeout will be called.boolean
Methods inherited from class akka.http.impl.engine.client.pool.SlotState.ConnectedState
isConnected, onNewConnectionEmbargo
Methods inherited from class akka.http.impl.engine.client.pool.SlotState
idle, illegalState, isIdle, name, onConnectionAttemptFailed, onConnectionAttemptSucceeded, onConnectionCompleted, onConnectionFailed, onNewRequest, onPreConnect, onRequestDispatched, onRequestEntityFailed, onResponseDispatchable, onResponseEntityCompleted, onResponseEntityFailed, onResponseReceived, onShutdown
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
Methods inherited from interface akka.http.impl.engine.client.pool.SlotState.BusyState
failOngoingRequest, isIdle, onConnectionAttemptFailed, onShutdown
Methods inherited from interface akka.http.impl.engine.client.pool.SlotState.BusyWithResultAlreadyDetermined
onConnectionCompleted, onConnectionFailed, onRequestEntityFailed, onResponseEntityFailed
-
Constructor Details
-
WaitingForResponseEntitySubscription
public WaitingForResponseEntitySubscription(PoolFlow.RequestContext ongoingRequest, HttpResponse ongoingResponse, scala.concurrent.duration.Duration stateTimeout, boolean waitingForEndOfRequestEntity)
-
-
Method Details
-
ongoingRequest
- Specified by:
ongoingRequest
in interfaceSlotState.BusyState
-
ongoingResponse
-
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
-
waitingForEndOfRequestEntity
public boolean waitingForEndOfRequestEntity()- Specified by:
waitingForEndOfRequestEntity
in interfaceSlotState.BusyState
-
onRequestEntityCompleted
Description copied from class:SlotState
Will be called either immediately if the request entity is strict or otherwise later- Overrides:
onRequestEntityCompleted
in classSlotState
-
onResponseEntitySubscribed
- Overrides:
onResponseEntitySubscribed
in classSlotState
-
onTimeout
-