- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for retrying (0.25 sec)
-
okhttp-sse/src/test/java/okhttp3/sse/internal/ServerSentEventIteratorTest.kt
} @Test fun namePrefixIgnored() { consumeEvents( """ |data: a |eventually |database |identity |retrying | | """.trimMargin(), ) assertThat(callbacks.remove()).isEqualTo(Event(null, null, "a")) } @Test fun nakedNameClearsIdAndTypeAppendsData() { consumeEvents(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
MockResponse( code = 503, headers = headersOf("Retry-After", "0"), body = "please retry", ), ) server.enqueue( MockResponse(body = "thank you for retrying"), ) val request = Request( url = server.url("/"), body = object : RequestBody() { var attempt = 0
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/src/main/kotlin/okhttp3/Authenticator.kt
* } * } * return null; // Didn't find a preemptive auth scheme. * ``` * * ## Reactive Authentication * * Implementations authenticate by returning a follow-up request that includes an authorization * header, or they may decline the challenge by returning null. In this case the unauthenticated * response will be returned to the caller that triggered it. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
* true when removing a connection from the pool; otherwise a racing caller might get it from the * pool when it shouldn't. Symmetrically, this must always be checked before returning a * connection from the pool. * * Once true this is always true. Guarded by this. */ var noNewExchanges = false /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
* * **Unreachable proxy servers.** A [ProxySelector] can be used to * attempt multiple proxy servers in sequence, eventually falling back to a direct * connection. * * Set this to false to avoid retrying requests when doing so is destructive. In this case the * calling application should do its own recovery of connectivity failures. */ fun retryOnConnectionFailure(retryOnConnectionFailure: Boolean) =
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/Task.kt
* from being scheduled. * * Tasks may opt-out of cancellation with `cancelable = false`. Such tasks will recur until they * decide not to by returning -1L. * * Task Queues * ----------- * * Tasks are bound to the [TaskQueue] they are scheduled in. Each queue is sequential and the tasks
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/android/DeferredSocketAdapter.kt
* * We use this because eager classpath checks cause confusion and excessive logging in Android, * and we can't rely on classnames after proguard, so are probably best served by falling through * to a situation of trying our least likely noisiest options. */ class DeferredSocketAdapter(private val socketAdapterFactory: Factory) : SocketAdapter { private var delegate: SocketAdapter? = null override fun isSupported(): Boolean {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
import okhttp3.internal.connection.RoutePlanner.ConnectResult import okhttp3.internal.connection.RoutePlanner.Plan import okhttp3.internal.okHttpName /** * Speculatively connects to each IP address of a target address, returning as soon as one of them * connects successfully. This kicks off new attempts every 250 ms until a connect succeeds. */ internal class FastFallbackExchangeFinder( override val routePlanner: RoutePlanner,
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) -
okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt
if (originalDurationNs == Long.MAX_VALUE) { timeout().clearDeadline() } else { timeout().deadlineNanoTime(nowNs + originalDurationNs) } } } /** * Attempts to exhaust this, returning true if successful. This is useful when reading a complete * source is helpful, such as when doing so completes a cache body or frees a socket connection for * reuse. */ internal fun Source.discard( timeout: Int,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/CacheControl.kt
/** * In a response, this field's name "no-cache" is misleading. It doesn't prevent us from caching * the response; it only means we have to validate the response with the origin server before * returning it. We can do this with a conditional GET. * * In a request, it means do not use a cache to satisfy the request. */ @get:JvmName("noCache") val noCache: Boolean,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:41:01 GMT 2024 - 10K bytes - Viewed (0)