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

Class SlotStateSpec.MockSlotContext

java.lang.Object

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

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

All Implemented Interfaces:

org.apache.pekko.macros.LogHelper, org.apache.pekko.macros.LogHelperMacro

Enclosing class:

SlotStateSpec

public class SlotStateSpec.MockSlotContext
extends SlotContext

Constructor Summary

Constructors

Constructor	Description
MockSlotContext(org.apache.pekko.event.LoggingAdapter _log, ConnectionPoolSettings settings)

Method Summary

Modifier and Type	Method	Description
boolean	connectionClosed()
boolean	connectionOpenRequested()
scala.Option<scala.util.Try<HttpResponse>>	dispatchedResponse()
void	dispatchResponseResult(PoolFlow.RequestContext req, scala.util.Try<HttpResponse> result)
<T> T	expectOpenConnection(scala.Function0<T> cb)
boolean	isConnectionClosed()
org.apache.pekko.event.LoggingAdapter	log()
void	openConnection()
scala.Option<HttpRequest>	pushedRequest()
ConnectionPoolSettings	settings()
boolean	willCloseAfter(HttpResponse response)

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.macros.LogHelper

isDebugEnabled, isInfoEnabled, isWarningEnabled, prefixString

Constructor Details

MockSlotContext

public MockSlotContext(org.apache.pekko.event.LoggingAdapter _log,
 ConnectionPoolSettings settings)

Method Details

settings

public ConnectionPoolSettings settings()

Specified by:

settings in class SlotContext

log

public org.apache.pekko.event.LoggingAdapter log()

connectionClosed

public boolean connectionClosed()

connectionOpenRequested

public boolean connectionOpenRequested()

pushedRequest

public scala.Option<HttpRequest> pushedRequest()

dispatchedResponse

public scala.Option<scala.util.Try<HttpResponse>> dispatchedResponse()

openConnection

public void openConnection()

Specified by:

openConnection in class SlotContext

isConnectionClosed

public boolean isConnectionClosed()

Specified by:

isConnectionClosed in class SlotContext

dispatchResponseResult

public void dispatchResponseResult(PoolFlow.RequestContext req,
 scala.util.Try<HttpResponse> result)

Specified by:

dispatchResponseResult in class SlotContext

willCloseAfter

public boolean willCloseAfter(HttpResponse response)

Specified by:

willCloseAfter in class SlotContext

expectOpenConnection

public <T> T expectOpenConnection(scala.Function0<T> cb)