public class SlotStateSpec.MockSlotContext extends SlotContext
Constructor and Description |
---|
MockSlotContext(org.apache.pekko.event.LoggingAdapter _log,
ConnectionPoolSettings settings) |
Modifier and Type | Method and 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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public MockSlotContext(org.apache.pekko.event.LoggingAdapter _log, ConnectionPoolSettings settings)
public ConnectionPoolSettings settings()
settings
in class SlotContext
public org.apache.pekko.event.LoggingAdapter log()
public boolean connectionClosed()
public boolean connectionOpenRequested()
public scala.Option<HttpRequest> pushedRequest()
public scala.Option<scala.util.Try<HttpResponse>> dispatchedResponse()
public void openConnection()
openConnection
in class SlotContext
public boolean isConnectionClosed()
isConnectionClosed
in class SlotContext
public void dispatchResponseResult(PoolFlow.RequestContext req, scala.util.Try<HttpResponse> result)
dispatchResponseResult
in class SlotContext
public boolean willCloseAfter(HttpResponse response)
willCloseAfter
in class SlotContext
public <T> T expectOpenConnection(scala.Function0<T> cb)