Lines Matching refs:drain
71 private static <T> int drain(BlockingQueue<T> q, Collection<? super T> buffer, int maxElements,
74 ? Queues.drain(q, buffer, maxElements, timeout, unit)
94 int elements = drain(q, buf, 100, Long.MAX_VALUE, TimeUnit.NANOSECONDS, interruptibly);
109 assertEquals(0, Queues.drain(q, ImmutableList.of(), 1, 10, TimeUnit.MILLISECONDS));
117 int drained = drain(q, Lists.newArrayList(), 2, 10, TimeUnit.MILLISECONDS, interruptibly);
138 // asking to drain zero elements
139 assertEquals(0, drain(q, ImmutableList.of(), 0, 10, TimeUnit.MILLISECONDS, interruptibly));
163 int elements = Queues.drain(q, buf, -1, Long.MAX_VALUE, TimeUnit.NANOSECONDS);
169 Queues.drain(q, buf, 1, Long.MAX_VALUE, TimeUnit.NANOSECONDS);
181 Queues.drain(q, ImmutableList.of(), 100, Long.MAX_VALUE, TimeUnit.NANOSECONDS);
223 * Checks that #drain() invocations behave correctly for a drained (empty) queue.
232 // nothing to drain, thus this should wait doing nothing
234 assertEquals(0, Queues.drain(q, ImmutableList.of(), 0, 10, TimeUnit.MILLISECONDS));
243 Queues.drain(q, Lists.newArrayList(), 1, Long.MAX_VALUE, TimeUnit.NANOSECONDS);