- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 69 for isCanceled (0.12 sec)
-
okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt
call.timeout().timeout(250, TimeUnit.MILLISECONDS) assertFailsWith<IOException> { call.execute() }.also { expected -> assertThat(expected.message).isEqualTo("timeout") assertThat(call.isCanceled()).isTrue() } } @Test fun timeoutWritingRequestWithEnqueue() { server.enqueue(MockResponse()) val request = Request.Builder() .url(server.url("/"))
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/SequentialExchangeFinder.kt
override val routePlanner: RoutePlanner, ) : ExchangeFinder { override fun find(): RealConnection { var firstException: IOException? = null while (true) { if (routePlanner.isCanceled()) throw IOException("Canceled") try { val plan = routePlanner.plan() if (!plan.isReady) { val tcpConnectResult = plan.connectTcp() val connectResult =
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/CallConnectionUser.kt
connection.connectionListener.noNewExchanges(connection) } override fun doExtensiveHealthChecks(): Boolean { return chain.request.method != "GET" } override fun isCanceled(): Boolean { return call.isCanceled() } override fun candidateConnection(): RealConnection? { return call.connection } override fun proxySelectStart(url: HttpUrl) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Mar 06 17:33:38 UTC 2024 - 3.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DispatcherTest.kt
assertThat(a1.isExecuted()).isTrue() assertThat(a1.isCanceled()).isFalse() assertThat(a2.isExecuted()).isTrue() assertThat(a2.isCanceled()).isTrue() assertThat(a3.isExecuted()).isFalse() assertThat(a3.isCanceled()).isTrue() assertThat(a4.isExecuted()).isFalse() assertThat(a4.isCanceled()).isFalse() } @Test fun idleCallbackInvokedWhenIdle() {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Fri Apr 05 03:30:42 UTC 2024 - 12.7K bytes - Viewed (0) -
okhttp-coroutines/src/test/kotlin/okhttp3/coroutines/ExecuteAsyncTest.kt
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Apr 18 01:24:38 UTC 2024 - 5.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
private var routeSelector: RouteSelector? = null private var nextRouteToTry: Route? = null override val deferredPlans = ArrayDeque<Plan>() override fun isCanceled(): Boolean = connectionUser.isCanceled() @Throws(IOException::class) override fun plan(): Plan { val reuseCallConnection = planReuseCallConnection() if (reuseCallConnection != null) return reuseCallConnection
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 12K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 17.9K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/FailingCall.kt
override fun enqueue(responseCallback: Callback): Unit = error("unexpected") override fun cancel(): Unit = error("unexpected") override fun isExecuted(): Boolean = error("unexpected") override fun isCanceled(): Boolean = error("unexpected") override fun timeout(): Timeout = error("unexpected") override fun clone(): Call = error("unexpected")
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 1.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectionUser.kt
fun connectionConnectionClosed(connection: RealConnection) fun noNewExchanges(connection: RealConnection) fun doExtensiveHealthChecks(): Boolean fun isCanceled(): Boolean fun candidateConnection(): RealConnection? fun proxySelectStart(url: HttpUrl) fun proxySelectEnd( url: HttpUrl, proxies: List<Proxy>, )
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Fri Apr 05 03:30:42 UTC 2024 - 2.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/PoolConnectionUser.kt
} override fun noNewExchanges(connection: RealConnection) { } override fun doExtensiveHealthChecks(): Boolean = false override fun isCanceled(): Boolean = false override fun candidateConnection(): RealConnection? = null override fun proxySelectStart(url: HttpUrl) { } override fun proxySelectEnd( url: HttpUrl,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Apr 03 20:39:41 UTC 2024 - 2.6K bytes - Viewed (0)