Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 269 for Execute (0.14 sec)

  1. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

          MockResponse(body = "GHI"),
        )
        val call1 = client.newCall(Request(server.url("/")))
        val response1 = call1.execute()
        val call2 = client.newCall(Request(server.url("/")))
        val response2 = call2.execute()
        val call3 = client.newCall(Request(server.url("/")))
        val response3 = call3.execute()
        assertThat(response1.body.string()).isEqualTo("ABC")
        assertThat(response2.body.string()).isEqualTo("DEF")
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 11 22:09:35 GMT 2024
    - 75.3K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/InterceptorTest.kt

                  val responseA = client.newCall(requestA).execute()
                  assertThat(responseA.body.string()).isEqualTo("a")
                }
                chain.proceed(chain.request())
              },
            )
            .build()
        val requestB =
          Request.Builder()
            .url(server.url("/b"))
            .build()
        val responseB = client.newCall(requestB).execute()
        assertThat(responseB.body.string()).isEqualTo("b")
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Jan 14 10:20:09 GMT 2024
    - 27.8K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/Call.kt

      fun cancel()
    
      /**
       * Returns true if this call has been either [executed][execute] or [enqueued][enqueue]. It is an
       * error to execute a call more than once.
       */
      fun isExecuted(): Boolean
    
      fun isCanceled(): Boolean
    
      /**
       * Returns a timeout that spans the entire call: resolving DNS, connecting, writing the request
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Dec 20 23:27:07 GMT 2023
    - 3.6K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

        }
      }
    
      /**
       * Returns an immediately-executable task for the calling thread to execute, sleeping as necessary
       * until one is ready. If there are no ready queues, or if other threads have everything under
       * control this will return null. If there is more than a single task ready to execute immediately
       * this will start another thread to handle that work.
       */
      fun awaitTaskToRun(): Task? {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/FastFallbackTest.kt

          MockResponse(body = "unexpected call to IPv4"),
        )
        serverIpv6.enqueue(
          MockResponse(body = "hello from IPv6"),
        )
    
        val call = client.newCall(Request(url))
        val response = call.execute()
        assertThat(response.body.string()).isEqualTo("hello from IPv6")
    
        // In the process we made one successful connection attempt.
        assertThat(listener.recordedEventTypes().filter { it == "ConnectStart" }).hasSize(1)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 10.3K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/Dispatcher.kt

       * was run [asynchronously][Call.enqueue] or [synchronously][Call.execute]. Asynchronous calls
       * become idle after the [onResponse][Callback.onResponse] or [onFailure][Callback.onFailure]
       * callback has returned. Synchronous calls become idle once [execute()][Call.execute] returns.
       * This means that if you are doing synchronous calls the network layer will not truly be idle
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 9K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/SocksProxyTest.kt

            .build()
        val request1 = Request.Builder().url(server.url("/")).build()
        val response1 = client.newCall(request1).execute()
        assertThat(response1.body.string()).isEqualTo("abc")
        val request2 = Request.Builder().url(server.url("/")).build()
        val response2 = client.newCall(request2).execute()
        assertThat(response2.body.string()).isEqualTo("def")
    
        // The HTTP calls should share a single connection.
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 3.5K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/EventListenerTest.kt

        client.newCall(
          Request.Builder()
            .url(server.url("/"))
            .build(),
        ).execute().close()
        listener.removeUpToEvent<CallEnd>()
        val call =
          client.newCall(
            Request.Builder()
              .url(server.url("/"))
              .build(),
          )
        val response = call.execute()
        response.close()
        assertThat(listener.recordedEventTypes()).containsExactly(
          "CallStart",
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 56.9K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/CallKotlinTest.kt

        server.enqueue(MockResponse(body = "def"))
    
        val request = Request(server.url("/"))
    
        val call = client.newCall(request)
        val response1 = call.execute()
    
        val cloned = call.clone()
        val response2 = cloned.execute()
    
        assertThat("abc").isEqualTo(response1.body.string())
        assertThat("def").isEqualTo(response2.body.string())
      }
    
      @Test
      @Flaky
      fun testMockWebserverRequest() {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 8.4K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt

            .post(sleepingRequestBody(500))
            .build()
        val call = client.newCall(request)
        call.timeout().timeout(250, TimeUnit.MILLISECONDS)
        assertFailsWith<IOException> {
          call.execute()
        }.also { expected ->
          assertThat(expected.message).isEqualTo("timeout")
          assertThat(call.isCanceled()).isTrue()
        }
      }
    
      @Test
      fun timeoutWritingRequestWithEnqueue() {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 10.5K bytes
    - Viewed (0)
Back to top