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, waitpublic MockSlotContext(org.apache.pekko.event.LoggingAdapter _log,
ConnectionPoolSettings settings)
public ConnectionPoolSettings settings()
settings in class SlotContextpublic 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 SlotContextpublic boolean isConnectionClosed()
isConnectionClosed in class SlotContextpublic void dispatchResponseResult(PoolFlow.RequestContext req, scala.util.Try<HttpResponse> result)
dispatchResponseResult in class SlotContextpublic boolean willCloseAfter(HttpResponse response)
willCloseAfter in class SlotContextpublic <T> T expectOpenConnection(scala.Function0<T> cb)