- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for Canceled (0.17 sec)
-
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/internal/connection/ConnectPlan.kt
internal val connectionSpecIndex: Int, internal val isTlsFallback: Boolean, ) : RoutePlanner.Plan, ExchangeCodec.Carrier { /** True if this connect was canceled; typically because it lost a race. */ @Volatile private var canceled = false // These properties are initialized by connect() and never reassigned. /** The low-level TCP socket. */ private var rawSocket: Socket? = null /**
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/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
"plan 0 cancel", "plan 1 cancel", ) taskFaker.advanceUntil(510.ms) assertEvents( "plan 1 TCP connect canceled", ) taskFaker.advanceUntil(520.ms) assertEvents( "plan 0 TCP connect canceled", ) } @Test fun takeMultipleConnections() { val plan0 = routePlanner.addPlan() plan0.connectState = TLS_CONNECTED
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 20.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/EventListener.kt
) { } /** * Invoked when a call is canceled. * * Like all methods in this interface, this is invoked on the thread that triggered the event. But * while other events occur sequentially; cancels may occur concurrently with other events. For * example, thread A may be executing [responseBodyStart] while thread B executes [canceled]. * Implementations must support such concurrent calls. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
assertThat(events).startsWith("CallStart", "ConnectStart", "ConnectEnd", "ConnectionAcquired") if (cancelMode == CANCEL) { assertThat(events).contains("Canceled") } else { assertThat(events).doesNotContain("Canceled") } assertThat(events).contains("ResponseFailed") assertThat(events).contains("ConnectionReleased") val call2 = client.newCall(Request(server.url("/")))
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 9.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
} @Test fun cancelAllWhenEmptyDoesNotStartWorkerThread() { redQueue.execute("red task", 100.µs) { error("expected to be canceled") } assertThat(taskFaker.executeCallCount).isEqualTo(1) blueQueue.execute("task", 100.µs) { error("expected to be canceled") } assertThat(taskFaker.executeCallCount).isEqualTo(1) redQueue.cancelAll()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 23K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
Typically this would cause certain redirects to fail in debug and development configurations. ## Version 4.4.0 _2020-02-17_ * New: Support `canceled()` as an event that can be observed by `EventListener`. This should be useful for splitting out canceled calls in metrics. * New: Publish a [bill of materials (BOM)][bom] for OkHttp. Depend on this from Gradle or Maven to
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt
import okhttp3.internal.stripBody import okhttp3.internal.withSuppressed /** * This interceptor recovers from failures and follows redirects as necessary. It may throw an * [IOException] if the call was canceled. */ class RetryAndFollowUpInterceptor(private val client: OkHttpClient) : Interceptor { @Throws(IOException::class) override fun intercept(chain: Interceptor.Chain): Response {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:24:48 GMT 2024 - 12.1K bytes - Viewed (4) -
docs/changelogs/changelog_2x.md
requests couldn't be canceled by tag. This update avoids crashing when `onResponse()` throws an `IOException`. That failure will now be logged instead of notifying the thread's uncaught exception handler. We've added a new API, `Call.isCanceled()` to check if a call has been canceled. * New: Update `MultipartBuilder` to support content length.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 26.6K bytes - Viewed (0)