Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 304 for Dequeue (0.1 sec)

  1. okhttp/src/test/java/okhttp3/ConnectionReuseTest.kt

      }
    
      @Test
      fun connectionsAreReused() {
        server.enqueue(MockResponse(body = "a"))
        server.enqueue(MockResponse(body = "b"))
        val request = Request(server.url("/"))
        assertConnectionReused(request, request)
      }
    
      @Test
      fun connectionsAreReusedForPosts() {
        server.enqueue(MockResponse(body = "a"))
        server.enqueue(MockResponse(body = "b"))
        val request =
          Request(
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  2. platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/ExclusiveCacheAccessingWorkerTest.groovy

            given:
            def counter = 0
            def failure = new RuntimeException()
            start(cacheAccessWorker)
    
            when:
            cacheAccessWorker.enqueue { throw failure }
            cacheAccessWorker.enqueue { throw new RuntimeException() }
            cacheAccessWorker.enqueue { counter++ }
            cacheAccessWorker.flush()
    
            then:
            counter == 1
            def e = thrown(RuntimeException)
            e == failure
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:08:47 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/CallTest.kt

      @Test
      fun connectionPooling_Async() {
        server.enqueue(MockResponse(body = "abc"))
        server.enqueue(MockResponse(body = "def"))
        server.enqueue(MockResponse(body = "ghi"))
        client.newCall(Request.Builder().url(server.url("/a")).build()).enqueue(callback)
        callback.await(server.url("/a")).assertBody("abc")
        client.newCall(Request.Builder().url(server.url("/b")).build()).enqueue(callback)
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 142.5K bytes
    - Viewed (0)
  4. docs/fr/docs/tutorial/query-params.md

    # Paramètres de requête
    
    Quand vous déclarez des paramètres dans votre fonction de chemin qui ne font pas partie des paramètres indiqués dans le chemin associé, ces paramètres sont automatiquement considérés comme des paramètres de "requête".
    
    ```Python hl_lines="9"
    {!../../../docs_src/query_params/tutorial001.py!}
    ```
    
    La partie appelée requête (ou **query**) dans une URL est l'ensemble des paires clés-valeurs placées après le `?` , séparées par des `&`.
    
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Wed Sep 27 20:52:31 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/EventListenerTest.kt

        enableTlsWithTunnel()
        server.enqueue(
          MockResponse.Builder()
            .inTunnel()
            .code(407)
            .addHeader("Proxy-Authenticate: Basic realm=\"localhost\"")
            .addHeader("Connection: close")
            .build(),
        )
        server.enqueue(
          MockResponse.Builder()
            .inTunnel()
            .build(),
        )
        server.enqueue(MockResponse())
        client =
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 56.9K bytes
    - Viewed (0)
  6. docs/fr/docs/tutorial/body.md

    # Corps de la requête
    
    Quand vous avez besoin d'envoyer de la donnée depuis un client (comme un navigateur) vers votre API, vous l'envoyez en tant que **corps de requête**.
    
    Le corps d'une **requête** est de la donnée envoyée par le client à votre API. Le corps d'une **réponse** est la donnée envoyée par votre API au client.
    
    Votre API aura presque toujours à envoyer un corps de **réponse**. Mais un client n'a pas toujours à envoyer un corps de **requête**.
    
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Fri Mar 22 01:42:11 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt

        server.enqueue(MockResponse())
        val request =
          Request.Builder()
            .url(server.url("/"))
            .post(sleepingRequestBody(500))
            .build()
        val latch = CountDownLatch(1)
        val exceptionRef = AtomicReference<Throwable>()
        val call = client.newCall(request)
        call.timeout().timeout(250, TimeUnit.MILLISECONDS)
        call.enqueue(
          object : Callback {
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/CacheTest.kt

      @Test
      fun redirectToCachedResult() {
        server.enqueue(
          MockResponse.Builder()
            .addHeader("Cache-Control: max-age=60")
            .body("ABC")
            .build(),
        )
        server.enqueue(
          MockResponse.Builder()
            .code(HttpURLConnection.HTTP_MOVED_PERM)
            .addHeader("Location: /foo")
            .build(),
        )
        server.enqueue(
          MockResponse.Builder()
            .body("DEF")
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 108.6K bytes
    - Viewed (0)
  9. okhttp/src/test/java/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: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  10. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt

            .build()
        server.enqueue(
          MockResponse.Builder()
            .headersDelay(500, TimeUnit.MILLISECONDS)
            .setHeader("content-type", "text/event-stream")
            .body("data: hey\n\n")
            .build(),
        )
        newEventSource()
        listener.assertFailure("timeout")
      }
    
      @Test
      fun retainsAccept() {
        server.enqueue(
          MockResponse.Builder()
            .body(
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 6.6K bytes
    - Viewed (0)
Back to top