- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 339 for Dequeue (0.27 sec)
-
pkg/kubelet/util/queue/work_queue_test.go
} } func TestGetWork(t *testing.T) { q, clock := newTestBasicWorkQueue() q.Enqueue(types.UID("foo1"), -1*time.Minute) q.Enqueue(types.UID("foo2"), -1*time.Minute) q.Enqueue(types.UID("foo3"), 1*time.Minute) q.Enqueue(types.UID("foo4"), 1*time.Minute) expected := []types.UID{types.UID("foo1"), types.UID("foo2")} compareResults(t, expected, q.GetWork())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 2.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DuplexTest.kt
.requestIOException() .exhaustResponse() server.enqueue( MockResponse.Builder() .clearHeaders() .code(HttpURLConnection.HTTP_MOVED_PERM) .addHeader("Location: /b") .streamHandler(body) .build(), ) server.enqueue( MockResponse.Builder() .body("this is /b") .build(), )
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 23.9K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt
} @Disabled("Not actually failing where expected") @Test fun disconnectAtStart() { server.enqueue( MockResponse.Builder() .socketPolicy(DisconnectAtStart) .build(), ) server.enqueue(MockResponse()) // The jdk's HttpUrlConnection is a bastard. server.enqueue(MockResponse()) try { server.url("/a").toUrl().openConnection().getInputStream() fail<Unit>()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 23.5K bytes - Viewed (0) -
docs/fr/docs/advanced/path-operation-advanced-configuration.md
Ainsi, vous pouvez ajouter des données supplémentaires au schéma généré automatiquement. Par exemple, vous pouvez décider de lire et de valider la requête avec votre propre code, sans utiliser les fonctionnalités automatiques de validation proposée par Pydantic, mais vous pouvez toujours définir la requête dans le schéma OpenAPI. Vous pouvez le faire avec `openapi_extra` : ```Python hl_lines="20-37 39-40"
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/interface.go
// Dump saves and returns the instant internal state of the queue-set. // Note that dumping process will stop the queue-set from proceeding // any requests. // For debugging only. Dump(includeRequestDetails bool) debug.QueueSetDump } // QueueNoteFn is called when a request enters and leaves a queue type QueueNoteFn func(inQueue bool) // Request represents the remainder of the handling of one request
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 6.4K bytes - Viewed (0) -
docs/fr/docs/tutorial/query-params-str-validations.md
# Paramètres de requête et validations de chaînes de caractères **FastAPI** vous permet de déclarer des informations et des validateurs additionnels pour vos paramètres de requêtes. Commençons avec cette application pour exemple : ```Python hl_lines="9" {!../../../docs_src/query_params_str_validations/tutorial001.py!} ```
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Jul 27 18:53:21 UTC 2023 - 9.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/SocksProxyTest.kt
this.server = server socksProxy.play() } @AfterEach fun tearDown() { socksProxy.shutdown() } @Test fun proxy() { server.enqueue(MockResponse.Builder().body("abc").build()) server.enqueue(MockResponse.Builder().body("def").build()) val client = clientTestRule.newClientBuilder() .proxy(socksProxy.proxy()) .build()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/InterceptorTest.kt
.url(server.url("/")) .build() client.newCall(request).enqueue(callback) callback.await(request.url) .assertCode(200) .assertHeader("OkHttp-Intercepted", "yep") } @Test fun applicationInterceptorsCanMakeMultipleRequestsToServer() { server.enqueue(MockResponse.Builder().body("a").build()) server.enqueue(MockResponse.Builder().body("b").build()) client =
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Jan 14 10:20:09 UTC 2024 - 27.8K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/QueueElementTester.java
public void testElement_empty() { try { getQueue().element(); fail("emptyQueue.element() should throw"); } catch (NoSuchElementException expected) { } expectUnchanged(); } @CollectionSize.Require(ONE) public void testElement_size1() { assertEquals("size1Queue.element() should return first element", e0(), getQueue().element()); expectUnchanged(); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jan 09 20:10:38 UTC 2018 - 2.3K bytes - Viewed (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)
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jan 09 20:10:38 UTC 2018 - 2.1K bytes - Viewed (0)