- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 147 for Jill (0.16 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RouteSelector.kt
// Postponed routes are always tried last. For example, if we have 2 proxies and all the // routes for proxy1 should be postponed, we'll move to proxy2. Only after we've exhausted // all the good routes will we attempt the postponed routes. val proxy = nextProxy() for (inetSocketAddress in inetSocketAddresses) { val route = Route(address, proxy, inetSocketAddress) if (routeDatabase.shouldPostpone(route)) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Mar 06 17:33:38 GMT 2024 - 7.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/MultipartReader.kt
* * multipartReader.use { * while (true) { * val part = multipartReader.nextPart() ?: break * process(part.headers, part.body) * } * } * ``` * * Note that [nextPart] will skip any unprocessed data from the preceding part. If the preceding * part is particularly large or if the underlying source is particularly slow, the [nextPart] call * may be slow! *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
/** * Create or update incoming headers, creating the corresponding streams if necessary. Frames * that trigger this are HEADERS and PUSH_PROMISE. * * @param inFinished true if the sender will not send further frames. * @param streamId the stream owning these headers. * @param associatedStreamId the stream that triggered the sender to create this stream. */ fun headers(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 19.9K bytes - Viewed (0) -
docs/changelogs/changelog_1x.md
* New: Use ALPN on Android platforms that support it (4.4+) * New: CacheControl model and parser. * New: Protocol selection in MockWebServer. * Fix: Route selection shouldn't use TLS modes that we know will fail. * Fix: Cache SPDY responses even if the response body is closed prematurely. * Fix: Use strict timeouts when aborting a download. * Fix: Support Shoutcast HTTP responses like `ICY 200 OK`.
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) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt
val cacheRequest = cache.put(response.newBuilder().request(cacheNetworkRequest).build()) return cacheWritingResponse(cacheRequest, response).also { if (cacheResponse != null) { // This will log a conditional cache miss only. listener.cacheMiss(call) } } } if (HttpMethod.invalidatesCache(networkRequest.method)) { try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Mar 22 07:09:21 GMT 2024 - 10.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RouteFailureTest.kt
"ConnectionReleased", ) } @ParameterizedTest @ValueSource(booleans = [false, true]) fun proxyMoveTest(cleanShutdown: Boolean) { // Define a single Proxy at myproxy:8008 that will artificially move during the test val proxySelector = RecordingProxySelector() proxySelector.proxies.add(Proxy(Proxy.Type.HTTP, InetSocketAddress("myproxy", 8008)))
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 11.9K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
/** The task that's currently executing. Guarded by [TaskRunner.lock]. */ private var currentTask: SerialTask = TestThreadSerialTask /** The coordinator task if it's waiting, and how it will resume. Guarded by [TaskRunner.lock]. */ private var waitingCoordinatorTask: SerialTask? = null private var waitingCoordinatorInterrupted = false private var waitingCoordinatorNotified = false
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 12.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
} } /** * HTTP/2 only. Send a push promise header block. * * A push promise contains all the headers that pertain to a server-initiated request, and a * `promisedStreamId` to which response frames will be delivered. Push promise frames are sent as * a part of the response to `streamId`. The `promisedStreamId` has a priority of one greater than * `streamId`. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 11.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
routePlanner.defaultConnectionIdleAtNanos = expireLater setPolicy(pool, address, ConnectionPool.AddressPolicy(1)) assertThat(pool.connectionCount()).isEqualTo(1) // All other connections created will expire sooner routePlanner.defaultConnectionIdleAtNanos = expireSooner // Turn it into an http/2 connection that supports 5 concurrent streams // which can satisfy a larger policy
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/main/kotlin/okhttp3/Request.kt
/** * Override the [Request.url] for caching, if it is either polluted with * transient query params, or has a canonical URL possibly for a CDN. * * Note that POST requests will not be sent to the server if this URL is set * and matches a cached response. */ fun cacheUrlOverride(cacheUrlOverride: HttpUrl?) = apply { this.cacheUrlOverride = cacheUrlOverride }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:17:44 GMT 2024 - 10.5K bytes - Viewed (0)