Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 228 for dequeue (0.57 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/CallKotlinTest.kt

          override fun writeTo(sink: BufferedSink) {
            sink.writeUtf8("<element/>")
            sink.flush()
          }
        }
    
        server.enqueue(MockResponse(code = 201))
        server.enqueue(MockResponse(code = 204))
        server.enqueue(MockResponse(code = 204))
    
        val endpointUrl = server.url("/endpoint")
    
        var request =
          Request
            .Builder()
            .url(endpointUrl)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 8.4K bytes
    - Viewed (0)
  2. 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 Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/InterceptorTest.kt

            .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 =
          client
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 28.2K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/TrailersTest.kt

        trailers(Protocol.HTTP_1_1)
      }
    
      @Test
      fun trailersHttp2() {
        trailers(Protocol.HTTP_2)
      }
    
      private fun trailers(protocol: Protocol) {
        enableProtocol(protocol)
    
        server.enqueue(
          MockResponse
            .Builder()
            .addHeader("h1", "v1")
            .trailers(headersOf("t1", "v2"))
            .body(protocol, "Hello")
            .build(),
        )
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 07 18:57:05 UTC 2025
    - 18K bytes
    - Viewed (0)
  5. 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 :
    
    {* ../../docs_src/query_params_str_validations/tutorial001.py hl[9] *}
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sat Nov 09 16:39:20 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  6. 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` :
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sat Nov 09 16:39:20 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/HttpUpgradesTest.kt

              sendResponse("server says hello\n")
              receiveRequest("client says goodbye\n")
              sendResponse("server says goodbye\n")
              exhaustResponse()
              exhaustRequest()
            }
        server.enqueue(socketHandler.upgradeResponse())
    
        client
          .newCall(
            upgradeRequest(),
          ).execute()
          .use { response ->
            assertThat(response.code).isEqualTo(HTTP_SWITCHING_PROTOCOLS)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  8. 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);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  9. 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)
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Nov 14 23:40:07 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  10. 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: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Nov 14 23:40:07 UTC 2024
    - 2.3K bytes
    - Viewed (0)
Back to top