- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 302 for poll (0.64 sec)
-
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()); }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 2.3K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Queues.java
while (added < numElements) { // we could rely solely on #poll, but #drainTo might be more efficient when there are multiple // elements already available (e.g. LinkedBlockingQueue#drainTo locks only once) added += q.drainTo(buffer, numElements - added); if (added < numElements) { // not enough elements immediately available; will have to poll E e = q.poll(deadline - System.nanoTime(), TimeUnit.NANOSECONDS);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 16K bytes - Viewed (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()); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 2.3K bytes - Viewed (0) -
src/main/java/org/codelibs/core/crypto/CachedCipher.java
} catch (final UnsupportedEncodingException e) { throw new UnsupportedEncodingRuntimeException(e); } } protected Cipher pollEncryptoCipher() { Cipher cipher = encryptoQueue.poll(); if (cipher == null) { final SecretKeySpec sksSpec = new SecretKeySpec(key.getBytes(), algorithm); try { cipher = Cipher.getInstance(algorithm);
Java - Registered: Fri Apr 26 20:58:09 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 8.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
* like [poll]. It is only usable within task faker tasks. */ private inner class TaskFakerBlockingQueue<T>( val delegate: BlockingQueue<T>, ) : AbstractQueue<T>(), BlockingQueue<T> { override val size: Int = delegate.size private var editCount = 0 override fun poll(): T = delegate.poll() override fun poll( timeout: Long, unit: TimeUnit,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 12.5K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/MockStreamHandler.kt
while (true) { val action = actions.poll() ?: break action(stream) } } } return@FutureTask null } } /** Returns once all stream actions complete successfully. */ fun awaitSuccess() { val futureTask = results.poll(5, TimeUnit.SECONDS) ?: throw AssertionError("no onRequest call received")
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java
assertEquals(1, (int) mmHeap.peek()); assertEquals(1, (int) mmHeap.poll()); assertEquals(3, (int) mmHeap.peekLast()); assertEquals(2, (int) mmHeap.peek()); assertEquals(2, (int) mmHeap.poll()); assertEquals(3, (int) mmHeap.peekLast()); assertEquals(3, (int) mmHeap.peek()); assertEquals(3, (int) mmHeap.poll()); assertNull(mmHeap.peekLast()); assertNull(mmHeap.peek());
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Mar 07 18:34:03 GMT 2024 - 36.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java
assertEquals(1, (int) mmHeap.peek()); assertEquals(1, (int) mmHeap.poll()); assertEquals(3, (int) mmHeap.peekLast()); assertEquals(2, (int) mmHeap.peek()); assertEquals(2, (int) mmHeap.poll()); assertEquals(3, (int) mmHeap.peekLast()); assertEquals(3, (int) mmHeap.peek()); assertEquals(3, (int) mmHeap.poll()); assertNull(mmHeap.peekLast()); assertNull(mmHeap.peek());
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Mar 07 18:34:03 GMT 2024 - 36.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/duplex/AsyncRequestBody.kt
requestBodySinks.add(sink) } override fun isDuplex(): Boolean = true @Throws(InterruptedException::class) fun takeSink(): BufferedSink { return requestBodySinks.poll(5, SECONDS) ?: throw AssertionError("no sink to take") } fun assertNoMoreSinks() { assertTrue(requestBodySinks.isEmpty()) }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 1.5K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/Dispatcher.java
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Dec 15 19:31:54 GMT 2023 - 7.3K bytes - Viewed (0)