Searched refs:queue (Results 1 – 2 of 2) sorted by relevance
183 final BlockingQueue<String> queue = new ArrayBlockingQueue<>(messageCount); in testMessageChannel() local192 queue.add(message.getData()); in testMessageChannel()202 WebkitUtils.waitForNextQueueElement(queue)); in testMessageChannel()
237 public static <T> T waitForNextQueueElement(@NonNull BlockingQueue<T> queue) { in waitForNextQueueElement() argument239 T value = queue.poll(TEST_TIMEOUT_MS, TimeUnit.MILLISECONDS); in waitForNextQueueElement()