Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 280 for dequeue (0.09 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top