- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 203 for poll (0.02 seconds)
-
guava-testlib/src/com/google/common/collect/testing/testers/QueuePollTester.java
public void testPoll_empty() { assertNull("emptyQueue.poll() should return null", getQueue().poll()); expectUnchanged(); } @CollectionFeature.Require(SUPPORTS_REMOVE) @CollectionSize.Require(ONE) public void testPoll_size1() { assertEquals("size1Queue.poll() should return first element", e0(), getQueue().poll()); expectMissing(e0()); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Nov 14 23:40:07 GMT 2024 - 2.5K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/QueuePollTester.java
public void testPoll_empty() { assertNull("emptyQueue.poll() should return null", getQueue().poll()); expectUnchanged(); } @CollectionFeature.Require(SUPPORTS_REMOVE) @CollectionSize.Require(ONE) public void testPoll_size1() { assertEquals("size1Queue.poll() should return first element", e0(), getQueue().poll()); expectMissing(e0()); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Nov 14 23:40:07 GMT 2024 - 2.5K bytes - Click Count (0) -
guava/src/com/google/common/collect/ForwardingQueue.java
@Override public boolean offer(@ParametricNullness E o) { return delegate().offer(o); } @CanIgnoreReturnValue // TODO(cpovirk): Consider removing this? @Override public @Nullable E poll() { return delegate().poll(); } @CanIgnoreReturnValue @Override @ParametricNullness public E remove() { return delegate().remove(); } @Override public @Nullable E peek() {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 3.9K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/ForwardingQueue.java
@Override public boolean offer(@ParametricNullness E o) { return delegate().offer(o); } @CanIgnoreReturnValue // TODO(cpovirk): Consider removing this? @Override public @Nullable E poll() { return delegate().poll(); } @CanIgnoreReturnValue @Override @ParametricNullness public E remove() { return delegate().remove(); } @Override public @Nullable E peek() {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 3.9K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingBlockingQueue.java
return delegate().offer(e, timeout, unit); } @CanIgnoreReturnValue // TODO(kak): consider removing this @Override public @Nullable E poll(long timeout, TimeUnit unit) throws InterruptedException { return delegate().poll(timeout, unit); } @Override public void put(E e) throws InterruptedException { delegate().put(e); } @Override public int remainingCapacity() {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 3K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/collect/MinMaxPriorityQueueBenchmark.java
} } } /** * Implementation of the InvertedMinMaxPriorityQueue which forwards all calls to a * MinMaxPriorityQueue, except poll, which is forwarded to pollMax. That way we can benchmark * pollMax using the same code that benchmarks poll. */ static final class InvertedMinMaxPriorityQueue<T> extends ForwardingQueue<T> { MinMaxPriorityQueue<T> mmHeap;Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 4.4K bytes - Click Count (0) -
guava-tests/benchmark/com/google/common/collect/MinMaxPriorityQueueBenchmark.java
} } } /** * Implementation of the InvertedMinMaxPriorityQueue which forwards all calls to a * MinMaxPriorityQueue, except poll, which is forwarded to pollMax. That way we can benchmark * pollMax using the same code that benchmarks poll. */ static final class InvertedMinMaxPriorityQueue<T> extends ForwardingQueue<T> { MinMaxPriorityQueue<T> mmHeap;Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 4.4K bytes - Click Count (0) -
guava-tests/test/com/google/common/collect/SynchronizedQueueTest.java
@Override public boolean offer(E o) { assertTrue(Thread.holdsLock(mutex)); return delegate.offer(o); } @Override public @Nullable E poll() { assertTrue(Thread.holdsLock(mutex)); return delegate.poll(); } @Override public E remove() { assertTrue(Thread.holdsLock(mutex)); return delegate.remove(); } @OverrideCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jul 16 17:42:14 GMT 2025 - 4.8K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingBlockingDeque.java
} @Override public E take() throws InterruptedException { return delegate().take(); } @Override public @Nullable E poll(long timeout, TimeUnit unit) throws InterruptedException { return delegate().poll(timeout, unit); } @Override public int drainTo(Collection<? super E> c) { return delegate().drainTo(c); } @Override
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 4.3K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/ForwardingBlockingDeque.java
} @Override public E take() throws InterruptedException { return delegate().take(); } @Override public @Nullable E poll(long timeout, TimeUnit unit) throws InterruptedException { return delegate().poll(timeout, unit); } @Override public int drainTo(Collection<? super E> c) { return delegate().drainTo(c); } @Override
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 4.3K bytes - Click Count (0)