- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 68 for QThread (0.14 sec)
-
docs/features/calls.md
Calls are executed in one of two ways: * **Synchronous:** your thread blocks until the response is readable. * **Asynchronous:** you enqueue the request on any thread, and get [called back](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-callback/) on another thread when the response is readable.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 3.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt
package okhttp3.internal.concurrent import assertk.assertThat import assertk.assertions.isCloseTo import assertk.assertions.isEmpty import assertk.assertions.isEqualTo import assertk.assertions.isTrue import java.lang.Thread.UncaughtExceptionHandler import java.util.concurrent.LinkedBlockingDeque import java.util.concurrent.ThreadFactory import java.util.concurrent.TimeUnit import org.junit.jupiter.api.AfterEach import org.junit.jupiter.api.Tag
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) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
assertThat(realTaskRunner.activeQueues()).isNotEmpty() Thread.sleep(100) val threads = arrayOfNulls<Thread>(Thread.activeCount() * 2) Thread.enumerate(threads) for (t in threads) { if (t != null && t.name == "OkHttp TaskRunner") { t.interrupt() } } Thread.sleep(100) assertThat(realTaskRunner.activeQueues()).isEmpty() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt
Request.Builder() .url(server.url("/")) .build() val call = client.newCall(request) call.timeout().timeout(250, TimeUnit.MILLISECONDS) val response = call.execute() Thread.sleep(500) assertFailsWith<IOException> { response.body.source().readUtf8() }.also { expected -> assertThat(expected.message).isEqualTo("timeout") assertThat(call.isCanceled()).isTrue()
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) -
okhttp/src/test/java/okhttp3/DispatcherTest.kt
} private fun makeSynchronousCall(call: Call): Thread { val thread = Thread { try { call.execute() throw AssertionError() } catch (expected: IOException) { } } thread.start() return thread } private fun newRequest(url: String): Request { return Request.Builder().url(url).build()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ResponseBody.kt
* * public void onFailure(Call call, IOException e) { * ... // Handle the failure. * } * }); * ``` * * These examples will not work if you're consuming the response body on another thread. In such * cases the consuming thread must call [close] when it has finished reading the response * body. * * ### The response body can be consumed only once. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
.build(), ) val webSocket: WebSocket = newWebSocket() clientListener.assertOpen() val server = serverListener.assertOpen() // Sleep longer than the HTTP client's read timeout. Thread.sleep((client.readTimeoutMillis + 500).toLong()) server.send("abc") clientListener.assertTextMessage("abc") closeWebSockets(webSocket, server) } @Test @Throws(Exception::class)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
docs/changelogs/changelog_1x.md
## Version 1.5.3 _2014-03-29_ * Fix bug where the Content-Length header was not always dropped when following a redirect from a POST to a GET. * Implement basic support for `Thread.interrupt()`. OkHttp now checks for an interruption before doing a blocking call. If it is interrupted, it throws an `InterruptedIOException`. ## Version 1.5.2 _2014-03-17_
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 6.4K bytes - Viewed (0) -
docs/changelogs/changelog_3x.md
`NullPointerException` or `OutOfMemoryError`. We now call `Callback.onFailure()` with an `IOException` that reports the call as canceled. The triggering exception is still delivered to the thread's `UncaughtExceptionHandler`. * Fix: Don't evict incomplete entries when iterating the cache. We had a bug where iterating `Cache.urls()` would prevent in-flight entries from being written. ## Version 3.14.3
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 14:55:54 GMT 2022 - 50.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
@Throws(InterruptedException::class, TimeoutException::class) private fun waitForConnectionShutdown(connection: RealConnection?) { if (connection!!.isHealthy(false)) { Thread.sleep(100L) } if (connection.isHealthy(false)) { Thread.sleep(2000L) } if (connection.isHealthy(false)) { throw TimeoutException("connection didn't shutdown within timeout") } } /**
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)