- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 159 for poll (0.12 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-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 May 03 12:43:13 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 May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 8.1K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/lifecycle/internal/stub/CompletionServiceStub.java
} public Future<ProjectSegment> take() throws InterruptedException { return null; } public Future<ProjectSegment> poll() { return null; } public Future<ProjectSegment> poll(long timeout, TimeUnit unit) throws InterruptedException { return null; }
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Wed Sep 06 08:39:32 GMT 2023 - 2.6K 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 May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
return null } private fun awaitTcpConnect( timeout: Long, unit: TimeUnit, ): ConnectResult? { if (tcpConnectsInFlight.isEmpty()) return null val result = connectResults.poll(timeout, unit) ?: return null tcpConnectsInFlight.remove(result.plan) return result } private fun cancelInFlightConnects() { for (plan in tcpConnectsInFlight) { plan.cancel()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.8K 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 May 03 11:42:14 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) -
guava/src/com/google/common/base/internal/Finalizer.java
/** * Starts the Finalizer thread. FinalizableReferenceQueue calls this method reflectively. * * @param finalizableReferenceClass FinalizableReference.class. * @param queue a reference queue that the thread will poll. * @param frqReference a phantom reference to the FinalizableReferenceQueue, which will be queued * either when the FinalizableReferenceQueue is no longer referenced anywhere, or when its * close() method is called.
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Wed Aug 23 12:54:09 GMT 2023 - 9.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
Object nextLabel; synchronized (PerListenerQueue.this) { Preconditions.checkState(isThreadScheduled); nextToRun = waitQueue.poll(); nextLabel = labelQueue.poll(); if (nextToRun == null) { isThreadScheduled = false; stillRunning = false; break; } }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 8.2K bytes - Viewed (0)