Package akka.http.impl.engine.client.pool

Interface SlotState.BusyState

All Known Subinterfaces:

SlotState.BusyWithResultAlreadyDetermined

All Known Implementing Classes:

SlotState.Connecting, SlotState.PushingRequestToConnection, SlotState.WaitingForEndOfResponseEntity, SlotState.WaitingForResponse, SlotState.WaitingForResponseDispatch, SlotState.WaitingForResponseEntitySubscription

Enclosing class:

SlotState

public static interface SlotState.BusyState

Method Summary

Modifier and Type	Method	Description
SlotState	failOngoingRequest(SlotContext ctx, java.lang.String signal, java.lang.Throwable cause)
boolean	isIdle()
SlotState	onConnectionAttemptFailed(SlotContext ctx, java.lang.Throwable cause)
SlotState	onConnectionCompleted(SlotContext ctx)
SlotState	onConnectionFailed(SlotContext ctx, java.lang.Throwable cause)
PoolFlow.RequestContext	ongoingRequest()
SlotState	onRequestEntityFailed(SlotContext ctx, java.lang.Throwable cause)
void	onShutdown(SlotContext ctx)
boolean	waitingForEndOfRequestEntity()

Method Detail

failOngoingRequest

SlotState failOngoingRequest(SlotContext ctx,
                             java.lang.String signal,
                             java.lang.Throwable cause)

isIdle

boolean isIdle()

onConnectionAttemptFailed

SlotState onConnectionAttemptFailed(SlotContext ctx,
                                    java.lang.Throwable cause)

onConnectionCompleted

SlotState onConnectionCompleted(SlotContext ctx)

onConnectionFailed

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

onRequestEntityFailed

SlotState onRequestEntityFailed(SlotContext ctx,
                                java.lang.Throwable cause)

onShutdown

void onShutdown(SlotContext ctx)

ongoingRequest

PoolFlow.RequestContext ongoingRequest()

waitingForEndOfRequestEntity

boolean waitingForEndOfRequestEntity()