- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 280 for dequeue (0.07 sec)
-
okhttp-coroutines/src/test/kotlin/okhttp3/coroutines/ExecuteAsyncTest.kt
@Test fun suspendCall() { runTest { server.enqueue(MockResponse(body = "abc")) val call = client.newCall(request) call.executeAsync().use { withContext(Dispatchers.IO) { assertThat(it.body.string()).isEqualTo("abc") } } } } @Test fun timeoutCall() { runTest { server.enqueue( MockResponse.Builder()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Apr 18 01:24:38 UTC 2024 - 5.4K bytes - Viewed (0) -
docs/fr/docs/tutorial/background-tasks.md
# Tâches d'arrière-plan Vous pouvez définir des tâches d'arrière-plan qui seront exécutées après avoir retourné une réponse. Ceci est utile pour les opérations qui doivent avoir lieu après une requête, mais où le client n'a pas réellement besoin d'attendre que l'opération soit terminée pour recevoir une réponse. Cela comprend, par exemple : * Les notifications par email envoyées après l'exécution d'une action :
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Mon Oct 28 10:29:51 UTC 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt
@Test fun serverDisconnectsBeforeSecondRequestHttp1() { enableProtocol(Protocol.HTTP_1_1) server.enqueue(MockResponse(code = 200, body = "Req1")) server.enqueue(MockResponse(code = 200, body = "Req2")) val eventListener = object : EventListener() { var socket: SSLSocket? = null var closed = false
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9.5K bytes - Viewed (0) -
src/main/resources/fess_message_fr.properties
errors.failed_to_find_plugins=Impossible d'accéder aux plugins disponibles. errors.failed_to_process_sso_request=Échec du traitement de la requête : {0} errors.invalid_query_unknown=La requête donnée a une condition inconnue. errors.invalid_query_parse_error=La requête donnée n'est pas valide. errors.invalid_query_sort_value=Le tri donné ({0}) n'est pas valide.
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Mon Feb 06 22:59:17 UTC 2023 - 14.2K bytes - Viewed (0) -
src/test/java/org/codelibs/opensearch/extension/analysis/NGramSynonymTokenizer.java
tokenizePartialBlock(nextStart, synonym.startOffset, afterSynonymProduced); // enqueue prev-synonym processPrevSynonym(synonym.startOffset, idx > 0 ? synonyms.get(idx - 1).endOffset : 0); if (expand) { queue.add(synonym); } // enqueue synonyms bytesReader.reset(synonym.output.bytes, synonym.output.offset, synonym.output.length);
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 17K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/ArbitraryInstances.java
import java.util.Currency; import java.util.Deque; import java.util.Iterator; import java.util.List; import java.util.ListIterator; import java.util.Locale; import java.util.Map; import java.util.NavigableMap; import java.util.NavigableSet; import java.util.Optional; import java.util.OptionalDouble; import java.util.OptionalInt; import java.util.OptionalLong; import java.util.Queue; import java.util.Random;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 21.2K bytes - Viewed (0) -
docs/fr/docs/index.md
* La documentation alternative reflétera également le nouveau paramètre de requête et le nouveau corps : ![ReDoc](https://fastapi.tiangolo.com/img/index/index-06-redoc-02.png) ### En résumé En résumé, vous déclarez **une fois** les types de paramètres, <abbr title="en anglais : body">le corps</abbr> de la requête, etc. en tant que paramètres de fonction. Vous faites cela avec les types Python standard modernes.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 20 19:20:23 UTC 2024 - 22K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/EvictingQueueTest.java
assertTrue(queue.add("one")); assertTrue(queue.add("two")); assertTrue(queue.add("three")); assertEquals("one", queue.element()); assertEquals("one", queue.peek()); assertEquals(3, queue.size()); assertEquals(0, queue.remainingCapacity()); assertTrue(queue.add("four")); assertEquals("two", queue.element()); assertEquals("two", queue.peek()); assertEquals(3, queue.size());
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Oct 15 17:36:06 UTC 2024 - 6.6K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Iterators.java
queue = new PriorityQueue<>(2, heapComparator); for (Iterator<? extends T> iterator : iterators) { if (iterator.hasNext()) { queue.add(Iterators.peekingIterator(iterator)); } } } @Override public boolean hasNext() { return !queue.isEmpty(); } @Override
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 50.3K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/AsynchronousGet.kt
private val client = OkHttpClient() fun run() { val request = Request.Builder() .url("http://publicobject.com/helloworld.txt") .build() client.newCall(request).enqueue( object : Callback { override fun onFailure( call: Call, e: IOException, ) { e.printStackTrace() } override fun onResponse(
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.6K bytes - Viewed (0)