org.apache.pekko.http.impl.engine.client.pool

Class SlotState.Idle

java.lang.Object

org.apache.pekko.http.impl.engine.client.pool.SlotState

org.apache.pekko.http.impl.engine.client.pool.SlotState.ConnectedState

org.apache.pekko.http.impl.engine.client.pool.SlotState.Idle

All Implemented Interfaces:

java.io.Serializable, SlotState.IdleState, scala.Equals, scala.Product

Enclosing class:

SlotState

public static final class SlotState.Idle
extends SlotState.ConnectedState
implements SlotState.IdleState, scala.Product, java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pekko.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 and Description
Idle(scala.concurrent.duration.Duration keepAliveTimeout)

Method Summary

Modifier and Type	Method and Description
scala.concurrent.duration.Duration	keepAliveTimeout()
SlotState	onConnectionCompleted(SlotContext ctx)
SlotState	onConnectionFailed(SlotContext ctx, java.lang.Throwable cause)
SlotState	onNewRequest(SlotContext ctx, PoolFlow.RequestContext requestContext)
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 org.apache.pekko.http.impl.engine.client.pool.SlotState.ConnectedState

isConnected, onNewConnectionEmbargo

Methods inherited from class org.apache.pekko.http.impl.engine.client.pool.SlotState

idle, illegalState, isIdle, name, onConnectionAttemptFailed, onConnectionAttemptSucceeded, onPreConnect, onRequestDispatched, onRequestEntityCompleted, onRequestEntityFailed, onResponseDispatchable, onResponseEntityCompleted, onResponseEntityFailed, onResponseEntitySubscribed, onResponseReceived, onShutdown

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.pekko.http.impl.engine.client.pool.SlotState.IdleState

isIdle

Methods inherited from interface scala.Product

$init$, productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

Idle

public Idle(scala.concurrent.duration.Duration keepAliveTimeout)

Method Detail

keepAliveTimeout

public scala.concurrent.duration.Duration keepAliveTimeout()

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 class SlotState

onNewRequest

public SlotState onNewRequest(SlotContext ctx,
                              PoolFlow.RequestContext requestContext)

Overrides:

onNewRequest in class SlotState

onTimeout

public SlotState onTimeout(SlotContext ctx)

Overrides:

onTimeout in class SlotState

onConnectionCompleted

public SlotState onConnectionCompleted(SlotContext ctx)

Overrides:

onConnectionCompleted in class SlotState

onConnectionFailed

public SlotState onConnectionFailed(SlotContext ctx,
                                    java.lang.Throwable cause)

Overrides:

onConnectionFailed in class SlotState