Searched refs:responseQueue (Results 1 – 3 of 3) sorted by relevance
27 protected final BlockingQueue<MockResponse> responseQueue = new LinkedBlockingQueue<>(); field in QueueDispatcher38 if (failFastResponse != null && responseQueue.peek() == null) { in dispatch()43 return responseQueue.take(); in dispatch()47 MockResponse peek = responseQueue.peek(); in peek()54 responseQueue.add(response); in enqueueResponse()
27 protected final BlockingQueue<MockResponse> responseQueue field in QueueDispatcher40 if (failFastResponse != null && responseQueue.peek() == null) { in dispatch()45 return responseQueue.take(); in dispatch()49 MockResponse peek = responseQueue.peek(); in peek()56 responseQueue.add(response); in enqueueResponse()
62 private final SynchronousQueue<Response> responseQueue = new SynchronousQueue<Response>(); field in TestThread146 assertNull(responseQueue.poll()); in callAndAssertBlocks()165 assertNull(responseQueue.poll()); in callAndAssertWaits()207 Response response = responseQueue.poll(TIMEOUT_MILLIS, TimeUnit.MILLISECONDS); in getResponse()245 responseQueue.put( in run()249 responseQueue.put(new Response(request.methodName, null, throwable)); in run()252 responseQueue.put(new Response(request.methodName, result, null)); in run()