- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 111 for canceled (0.16 sec)
-
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
ConnectResult(this, nextPlan = connectTcpNextPlan, throwable = tcpConnectThrowable) } canceled -> { events += "plan $id TCP connect canceled" ConnectResult(this, nextPlan = connectTcpNextPlan, throwable = IOException("canceled")) } connectTcpNextPlan != null -> { events += "plan $id needs follow-up"
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 6.2K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt
} } catch (e: Exception) { val exception = when { canceled -> IOException("canceled", e) else -> e } listener.onFailure(this, exception, response) return } if (canceled) { listener.onFailure(this, IOException("canceled"), response) } else { listener.onClosed(this) } } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
assertThat(client.canceled).isFalse() taskFaker.advanceUntil(ns(RealWebSocket.CANCEL_AFTER_CLOSE_MILLIS - 1)) assertThat(client.canceled).isFalse() taskFaker.advanceUntil(ns(RealWebSocket.CANCEL_AFTER_CLOSE_MILLIS)) assertThat(client.canceled).isTrue() client.processNextFrame() // This won't get a frame, but it will get a closed pipe.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
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) -
okhttp/src/main/kotlin/okhttp3/Call.kt
*/ fun enqueue(responseCallback: Callback) /** Cancels the request, if possible. Requests that are already complete cannot be canceled. */ 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 /**
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) -
okhttp-coroutines/src/test/kotlin/okhttp3/coroutines/ExecuteAsyncTest.kt
} }.buffer() }, ) .build() var responseClosed = false var canceled = false var afterCallbackOnResponse: () -> Unit = {} override fun cancel() { canceled = true } override fun enqueue(responseCallback: Callback) { responseCallback.onResponse(this, response) afterCallbackOnResponse()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:24:38 GMT 2024 - 5.4K bytes - Viewed (0) -
okhttp-coroutines/src/test/kotlin/okhttp3/SuspendCallTest.kt
} }.buffer() }, ) .build() var responseClosed = false var canceled = false var afterCallbackOnResponse: () -> Unit = {} override fun cancel() { canceled = true } override fun enqueue(responseCallback: Callback) { responseCallback.onResponse(this, response) afterCallbackOnResponse()
Plain Text - Registered: Fri Apr 12 11:42:09 GMT 2024 - Last Modified: Fri Apr 05 11:25:23 GMT 2024 - 5.3K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/ClientRuleEventListener.kt
call: Call, ioe: IOException, ) { logWithTime("callFailed: $ioe") delegate.callFailed(call, ioe) } override fun canceled(call: Call) { logWithTime("canceled") delegate.canceled(call) } override fun satisfactionFailure( call: Call, response: Response, ) { logWithTime("satisfactionFailure")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
else -> Socket(route.proxy) } this.rawSocket = rawSocket // Handle the race where cancel() precedes connectSocket(). We don't want to miss a cancel. if (canceled) { throw IOException("canceled") } rawSocket.soTimeout = socketReadTimeoutMillis try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 18.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
override fun find(): RealConnection { var firstException: IOException? = null try { while (tcpConnectsInFlight.isNotEmpty() || routePlanner.hasNext()) { if (routePlanner.isCanceled()) throw IOException("Canceled") // Launch a new connection if we're ready to. val now = taskRunner.backend.nanoTime() var awaitTimeoutNanos = nextTcpConnectAtNanos - now
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.8K bytes - Viewed (0)