Searched refs:throttlePolicy (Results 1 – 1 of 1) sorted by relevance
471 MockResponse throttlePolicy = dispatcher.peek(); in readRequest() local474 throttledTransfer(throttlePolicy, in, requestBody, contentLength); in readRequest()484 throttledTransfer(throttlePolicy, in, requestBody, chunkSize); in readRequest()528 private void throttledTransfer(MockResponse throttlePolicy, InputStream in, OutputStream out, in throttledTransfer() argument531 int bytesPerPeriod = throttlePolicy.getThrottleBytesPerPeriod(); in throttledTransfer()532 … long delayMs = throttlePolicy.getThrottleUnit().toMillis(throttlePolicy.getThrottlePeriod()); in throttledTransfer()