Lines Matching refs:RecordedRequest
55 private final BlockingQueue<RecordedRequest> requestQueue
56 = new LinkedBlockingQueue<RecordedRequest>();
99 public RecordedRequest takeRequest() throws InterruptedException {
103 public RecordedRequest takeRequestWithTimeout(long timeoutMillis) throws InterruptedException {
107 public List<RecordedRequest> drainRequests() {
108 List<RecordedRequest> requests = new ArrayList<RecordedRequest>();
155 RecordedRequest request = readRequest(in, sequenceNumber);
203 private RecordedRequest readRequest(InputStream in, int sequenceNumber) throws IOException {
256 return new RecordedRequest(request, headers, chunkSizes,
263 private MockResponse sendResponse(OutputStream out, RecordedRequest request)