Searched refs:readyQueue (Results 1 – 1 of 1) sorted by relevance
1899 private final BlockingQueue<Object> readyQueue = new LinkedBlockingQueue<Object>(); field in AbstractTransportTest.ServerStreamListenerBase1904 return readyQueue.poll(timeout, unit) != null; in awaitOnReady()1912 readyQueue.drainTo(Lists.newArrayList()); in awaitOnReadyAndDrain()1936 readyQueue.add(new Object()); in onReady()1959 private final BlockingQueue<Object> readyQueue = new LinkedBlockingQueue<Object>(); field in AbstractTransportTest.ClientStreamListenerBase1965 return readyQueue.poll(timeout, unit) != null; in awaitOnReady()1973 readyQueue.drainTo(Lists.newArrayList()); in awaitOnReadyAndDrain()1993 readyQueue.add(new Object()); in onReady()