- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 40 for execute (0.15 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
} eventListener.canceled(this) } override fun isCanceled(): Boolean = canceled override fun execute(): Response { check(executed.compareAndSet(false, true)) { "Already Executed" } timeout.enter() callStart() try { client.dispatcher.executed(this) return getResponseWithInterceptorChain() } finally { client.dispatcher.finished(this) } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
container-tests/src/test/java/okhttp3/containers/SocksProxyTest.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 2.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
check(serverSocket == null) serverSocket = ServerSocket() serverSocket!!.reuseAddress = false serverSocket!!.bind(InetSocketAddress("localhost", 0), 1) port = serverSocket!!.localPort executor.execute { try { readAndWriteFrames() } catch (e: IOException) { ******@****.***uietly() logger.info("${this@MockHttp2Peer} done: ${e.message}") } } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
.header("User-Agent", "SyncApiTest") .build() val call = client.newCall(request) val response = call.execute() response.body.close() assertFailsWith<IllegalStateException> { call.execute() }.also { expected -> assertThat(expected.message).isEqualTo("Already Executed") } assertFailsWith<IllegalStateException> { call.enqueue(callback) }.also { expected ->
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0) -
okhttp-logging-interceptor/src/test/java/okhttp3/logging/HttpLoggingInterceptorTest.kt
@Test fun none() { server.enqueue(MockResponse()) client.newCall(request().build()).execute() applicationLogs.assertNoMoreLogs() networkLogs.assertNoMoreLogs() } @Test fun basicGet() { setLevel(Level.BASIC) server.enqueue(MockResponse()) client.newCall(request().build()).execute() applicationLogs .assertLogEqual("--> GET $url")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 09:14:38 GMT 2024 - 37.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
server.enqueue(MockResponse(body = "A")) server.enqueue(MockResponse(body = "A")) val executor = Executors.newCachedThreadPool(threadFactory("HttpOverHttp2Test")) val countDownLatch = CountDownLatch(2) executor.execute(AsyncRequest("/r1", countDownLatch)) executor.execute(AsyncRequest("/r2", countDownLatch)) countDownLatch.await() assertThat(server.takeRequest().sequenceNumber).isEqualTo(0)
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) -
container-tests/src/test/java/okhttp3/containers/BasicProxyTest.kt
fun testOkHttpDirect() { testRequest { val client = OkHttpClient() val response = client.newCall( Request((mockServer.endpoint + "/person?name=peter").toHttpUrl()), ).execute() assertThat(response.body.string()).contains("Peter the person") assertThat(response.protocol).isEqualTo(Protocol.HTTP_1_1) } } @Test fun testOkHttpProxied() { testRequest {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 5.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
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) -
okhttp-android/src/test/kotlin/okhttp3/android/RobolectricOkHttpClientTest.kt
request.newBuilder() .build() val call = client.newCall(networkRequest) call.execute().use { response -> assertThat(response.code).isEqualTo(200) assertThat(response.cacheResponse).isNull() } val cachedCall = client.newCall(request) cachedCall.execute().use { response -> assertThat(response.code).isEqualTo(200) assertThat(response.cacheResponse).isNotNull()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 2.5K bytes - Viewed (0) -
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)