Searched refs:responseQueue (Results 1 – 5 of 5) sorted by relevance
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()
33 private final ArrayBlockingQueue<Optional<HandshakerResp>> responseQueue = field in AltsHandshakerStub59 if (!responseQueue.isEmpty()) { in send()63 Optional<HandshakerResp> result = responseQueue.take(); in send()87 AltsHandshakerStub.this.responseQueue.add(Optional.of(resp)); in onNext()102 AltsHandshakerStub.this.responseQueue.offer(result); in onError()111 AltsHandshakerStub.this.responseQueue.offer(result); in onCompleted()
29 protected final BlockingQueue<MockResponse> responseQueue = new LinkedBlockingQueue<>(); 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()
100 std::queue<std::shared_future<OperationResponse>> responseQueue; in main() local107 empty = responseQueue.empty(); in main()115 responseQueue.front().get(); in main()119 responseQueue.pop(); in main()136 responseQueue.push(responseFuture); in main()