HomeSort by relevance Sort by last modified time
    Searched refs:responseQueue (Results 1 - 4 of 4) sorted by null

  /external/mockwebserver/src/main/java/com/google/mockwebserver/
QueueDispatcher.java 27 protected final BlockingQueue<MockResponse> responseQueue
40 if (failFastResponse != null && responseQueue.peek() == null) {
45 return responseQueue.take();
49 MockResponse peek = responseQueue.peek();
56 responseQueue.add(response);
  /external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/
QueueDispatcher.java 27 protected final BlockingQueue<MockResponse> responseQueue = new LinkedBlockingQueue<>();
38 if (failFastResponse != null && responseQueue.peek() == null) {
43 return responseQueue.take();
47 MockResponse peek = responseQueue.peek();
54 responseQueue.add(response);
  /external/guava/guava-tests/test/com/google/common/util/concurrent/
TestThread.java 62 private final SynchronousQueue<Response> responseQueue = new SynchronousQueue<Response>();
146 assertNull(responseQueue.poll());
165 assertNull(responseQueue.poll());
207 Response response = responseQueue.poll(TIMEOUT_MILLIS, TimeUnit.MILLISECONDS);
245 responseQueue.put(
249 responseQueue.put(new Response(request.methodName, null, throwable));
252 responseQueue.put(new Response(request.methodName, result, null));
  /libcore/support/src/test/java/tests/http/
MockWebServer.java 68 private final BlockingQueue<MockResponse> responseQueue
145 responseQueue.add(response.clone());
222 MockResponse peek = responseQueue.peek();
224 responseQueue.take();
230 } while (!responseQueue.isEmpty());
272 while (!responseQueue.isEmpty() && processOneRequest(in, out, socket)) {}
281 if (responseQueue.isEmpty()) {
293 MockResponse connect = responseQueue.peek();
401 if (responseQueue.isEmpty()) {
413 return responseQueue.peek()
    [all...]

Completed in 2756 milliseconds