- Sort Score
- Num 10 results
- Language All
Results 61 - 70 of 318 for dequeue (0.05 seconds)
-
android/guava-testlib/src/com/google/common/collect/testing/testers/QueueElementTester.java
@CollectionSize.Require(ZERO) public void testElement_empty() { assertThrows(NoSuchElementException.class, () -> getQueue().element()); expectUnchanged(); } @CollectionSize.Require(ONE) public void testElement_size1() { assertEquals("size1Queue.element() should return first element", e0(), getQueue().element()); expectUnchanged(); } @CollectionFeature.Require(KNOWN_ORDER)
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Nov 14 23:40:07 GMT 2024 - 2.4K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/QueuePeekTester.java
@CollectionSize.Require(ZERO) public void testPeek_empty() { assertNull("emptyQueue.peek() should return null", getQueue().peek()); expectUnchanged(); } @CollectionSize.Require(ONE) public void testPeek_size1() { assertEquals("size1Queue.peek() should return first element", e0(), getQueue().peek()); expectUnchanged(); } @CollectionFeature.Require(KNOWN_ORDER) @CollectionSize.Require(SEVERAL)
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Nov 14 23:40:07 GMT 2024 - 2.3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
*/ public void enqueue(Event<L> event) { enqueueHelper(event, event); } /** * Enqueues an event to be run on currently known listeners, with a label. * * @param event the callback to execute on {@link #dispatch} * @param label a description of the event to use in the case of an error */ public void enqueue(Event<L> event, String label) { enqueueHelper(event, label);Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 8.1K bytes - Click Count (0) -
guava-testlib/src/com/google/common/collect/testing/testers/QueuePeekTester.java
@CollectionSize.Require(ZERO) public void testPeek_empty() { assertNull("emptyQueue.peek() should return null", getQueue().peek()); expectUnchanged(); } @CollectionSize.Require(ONE) public void testPeek_size1() { assertEquals("size1Queue.peek() should return first element", e0(), getQueue().peek()); expectUnchanged(); } @CollectionFeature.Require(KNOWN_ORDER) @CollectionSize.Require(SEVERAL)
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Nov 14 23:40:07 GMT 2024 - 2.3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
private void enqueueStartingEvent() { listeners.enqueue(STARTING_EVENT); } private void enqueueRunningEvent() { listeners.enqueue(RUNNING_EVENT); } private void enqueueStoppingEvent(State from) { if (from == State.STARTING) { listeners.enqueue(STOPPING_FROM_STARTING_EVENT); } else if (from == State.RUNNING) { listeners.enqueue(STOPPING_FROM_RUNNING_EVENT); } else {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Feb 19 21:24:11 GMT 2025 - 20.3K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/InsecureForHostTest.kt
} @Test fun `untrusted host in insecureHosts connects successfully`() { val serverCertificates = platform.localhostHandshakeCertificates() server.useHttps(serverCertificates.sslSocketFactory()) server.enqueue(MockResponse()) val clientCertificates = HandshakeCertificates .Builder() .addPlatformTrustedCertificates() .addInsecureHost(server.hostName) .build()Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Jun 18 12:28:21 GMT 2025 - 4.2K bytes - Click Count (0) -
mockwebserver/src/main/kotlin/mockwebserver3/QueueDispatcher.kt
// If take() returned because we're shutting down, then enqueue another dead letter so that any // other threads waiting on take() will also return. if (result == DEAD_LETTER) responseQueue.add(DEAD_LETTER) return result } public override fun peek(): MockResponse = responseQueue.peek() ?: failFastResponse ?: super.peek() public open fun enqueue(response: MockResponse) { responseQueue.add(response) }Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sat Jun 14 16:09:26 GMT 2025 - 2.9K bytes - Click Count (0) -
docs/fr/docs/tutorial/path-params-numeric-validations.md
# Paramètres de chemin et validations numériques { #path-parameters-and-numeric-validations } De la même façon que vous pouvez déclarer plus de validations et de métadonnées pour les paramètres de requête avec `Query`, vous pouvez déclarer le même type de validations et de métadonnées pour les paramètres de chemin avec `Path`. ## Importer `Path` { #import-path } Tout d'abord, importez `Path` de `fastapi`, et importez `Annotated` :Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:37:13 GMT 2026 - 7.1K bytes - Click Count (0) -
android-test/src/androidDeviceTest/java/okhttp/android/test/OkHttpTest.kt
enableTls() client = client .newBuilder() .eventListenerFactory(clientTestRule.wrap(eventRecorder)) .build() server.enqueue(MockResponse(body = "abc1")) server.enqueue(MockResponse(body = "abc2")) val request = Request.Builder().url(server.url("/")).build() client.newCall(request).execute().use { response -> assertEquals(200, response.code)Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 29.9K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/QueueOfferTester.java
public void testOffer_supportedNotPresent() { assertTrue("offer(notPresent) should return true", getQueue().offer(e3())); expectAdded(e3()); } @CollectionFeature.Require({SUPPORTS_ADD, ALLOWS_NULL_VALUES}) public void testOffer_nullSupported() { assertTrue("offer(null) should return true", getQueue().offer(null)); expectAdded((E) null); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Nov 14 23:40:07 GMT 2024 - 2.3K bytes - Click Count (0)