Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 226 for dequeue (0.07 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  2. 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
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 16:11:23 GMT 2025
    - 28.2K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

        )
      }
    
      @Test
      fun cancelAsyncCall() {
        server.enqueue(
          MockResponse
            .Builder()
            .body("abc")
            .build(),
        )
        val call =
          client.newCallWithListener(
            Request
              .Builder()
              .url(server.url("/"))
              .build(),
          )
        call.enqueue(
          object : Callback {
            override fun onFailure(
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 70.7K bytes
    - Click Count (0)
  4. docs/fr/docs/advanced/openapi-callbacks.md

    créer une API avec un *chemin d'accès* qui déclenche une requête vers une *API externe* créée par quelqu'un d'autre (probablement la même personne développeuse qui utiliserait votre API).
    
    Le processus qui se produit lorsque votre application API appelle l’*API externe* s’appelle un « callback ». Parce que le logiciel écrit par la personne développeuse externe envoie une requête à votre API puis votre API « rappelle », en envoyant une requête à une *API externe* (probablement créée par la même personne...
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:37:13 GMT 2026
    - 8.7K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/CookiesTest.kt

      }
    
      @Test
      fun receiveAndSendMultipleCookies() {
        server.enqueue(
          MockResponse
            .Builder()
            .addHeader("Set-Cookie", "a=android")
            .addHeader("Set-Cookie", "b=banana")
            .build(),
        )
        server.enqueue(MockResponse())
        val cookieManager = CookieManager(null, CookiePolicy.ACCEPT_ORIGINAL_SERVER)
        client =
          client
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Mar 19 07:46:39 GMT 2026
    - 14.5K bytes
    - Click Count (0)
  6. mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt

      }
    
      @Disabled("Not actually failing where expected")
      @Test
      fun disconnectAtStart() {
        server.enqueue(
          MockResponse
            .Builder()
            .onRequestStart(CloseSocket())
            .build(),
        )
        server.enqueue(MockResponse()) // The jdk's HttpUrlConnection is a bastard.
        server.enqueue(MockResponse())
        try {
          server
            .url("/a")
            .toUrl()
            .openConnection()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Aug 03 22:38:00 GMT 2025
    - 28K bytes
    - Click Count (0)
  7. 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(),
        )
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 18.8K bytes
    - Click Count (0)
  8. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt

      }
    
      @Disabled("Not actually failing where expected")
      @Test
      fun disconnectAtStart() {
        server.enqueue(
          MockResponse()
            .setSocketPolicy(SocketPolicy.DISCONNECT_AT_START),
        )
        server.enqueue(MockResponse()) // The jdk's HttpUrlConnection is a bastard.
        server.enqueue(MockResponse())
        try {
          server
            .url("/a")
            .toUrl()
            .openConnection()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 03 13:16:34 GMT 2025
    - 22.3K bytes
    - Click Count (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt

            .requestIOException()
            .exhaustResponse()
        server.enqueue(
          MockResponse
            .Builder()
            .clearHeaders()
            .code(HttpURLConnection.HTTP_MOVED_PERM)
            .addHeader("Location: /b")
            .socketHandler(body)
            .build(),
        )
        server.enqueue(
          MockResponse
            .Builder()
            .body("this is /b")
            .build(),
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 25.8K bytes
    - Click Count (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

        taskFaker.close()
        routePlanner.close()
      }
    
      @Test
      fun takeConnectedConnection() {
        val plan0 = routePlanner.addPlan()
        plan0.connectState = TLS_CONNECTED
    
        taskRunner.newQueue().execute("connect") {
          val result0 = finder.find()
          assertThat(result0).isEqualTo(plan0.connection)
        }
    
        taskFaker.runTasks()
        assertEvents(
          "take plan 0",
        )
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 20.9K bytes
    - Click Count (0)
Back to Top