- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 167 for From (0.13 sec)
-
okhttp/src/main/kotlin/okhttp3/CertificatePinner.kt
* at okhttp3.Connection.upgradeToTls(Connection.java) * at okhttp3.Connection.connect(Connection.java) * at okhttp3.Connection.connectAndSetOwner(Connection.java) * ``` * * Follow up by pasting the public key hashes from the exception into the * certificate pinner's configuration: * * ```java * CertificatePinner certificatePinner = new CertificatePinner.Builder()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 14.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
* 4. [Read response headers][readResponseHeaders]. * 5. Open a source to read the response body. Either [fixed-length][newFixedLengthSource], * [chunked][newChunkedSource] or [unknown][newUnknownLengthSource]. * 6. Read from and close that source. * * Exchanges that do not have a request body may skip creating and closing the request body. * Exchanges that do not have a response body can call
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
// We have a connected TCP connection. Cancel and defer the racing connects that all lost. cancelInFlightConnects() // Finish connecting. We won't have to if the winner is from the connection pool. if (!connectResult.plan.isReady) { connectResult = connectResult.plan.connectTlsEtc() } if (connectResult.isSuccess) {
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/connection/ConnectPlan.kt
* * * [TCP handshake][connectSocket] * * Optional [CONNECT tunnels][connectTunnel]. When using an HTTP proxy to reach an HTTPS server * we must send a `CONNECT` request, and handle authorization challenges from the proxy. * * Optional [TLS handshake][connectTls]. * * Each step may fail. If a retry is possible, a new instance is created with the next plan, which * will be configured differently. */ class ConnectPlan(
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/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/Request.kt
* headers like "Cookie". * * Note that for some headers including `Content-Length` and `Content-Encoding`, * OkHttp may replace [value] with a header derived from the request body. */ open fun addHeader( name: String, value: String, ) = commonAddHeader(name, value) /** Removes all headers named [name] on this builder. */
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) -
okhttp/src/test/java/okhttp3/CacheControlJvmTest.kt
assertThat(cacheControl.noTransform).isTrue() assertThat(cacheControl.toString()).isEqualTo(header) } @Test @Throws(Exception::class) fun parseIgnoreCacheControlExtensions() { // Example from http://www.w3.org/Protocols/rfc2616/rfc2616-sec14.html#sec14.9.6 val header = "private, community=\"UCI\"" val cacheControl = parse( Headers.Builder() .set("Cache-Control", header)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt
import okhttp3.internal.http.RealResponseBody import okhttp3.internal.http.promisesBody import okhttp3.internal.stripBody import okio.Buffer import okio.Source import okio.Timeout import okio.buffer /** Serves requests from the cache and writes responses to the cache. */ class CacheInterceptor(internal val cache: Cache?) : Interceptor { @Throws(IOException::class) override fun intercept(chain: Interceptor.Chain): Response {
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/main/kotlin/okhttp3/internal/-CacheControlCommon.kt
noTransform = noTransform, immutable = immutable, headerValue = headerValue, ) } /** * Returns the next index in this at or after [startIndex] that is a character from * [characters]. Returns the input length if none of the requested characters can be found. */ private fun String.indexOfElement( characters: String, startIndex: Int = 0, ): Int {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:41:01 GMT 2024 - 7.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
/** * Schedules immediate execution of [Task.tryCancel] on all currently-enqueued tasks. These calls * will not be made until any currently-executing task has completed. Tasks that return true will * be removed from the execution schedule. */ fun cancelAll() { lock.assertNotHeld() taskRunner.lock.withLock { if (cancelAllAndDecide()) { taskRunner.kickCoordinator(this) } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.5K bytes - Viewed (0)