- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 38 for selected (0.23 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/platform/Jdk8WithJettyBootPlatform.kt
if (protocol in protocols) { selected = protocol return selected } } selected = protocols[0] // On no intersection, try peer's first protocol. return selected } else if ((methodName == "protocolSelected" || methodName == "selected") && callArgs.size == 1) { this.selected = callArgs[0] as String // Server selected this protocol. return null
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/cache2/Relay.kt
* * ## The buffer * * In this case the bytes are immediately copied into [sink] and the number of bytes copied is * returned. * * If upstream would be selected but another thread is already reading upstream this will * block until that read completes. It is possible to time out while waiting for that. */ @Throws(IOException::class) override fun read(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/BouncyCastlePlatform.kt
override fun getSelectedProtocol(sslSocket: SSLSocket): String? = if (sslSocket is BCSSLSocket) { when (val protocol = (sslSocket as BCSSLSocket).applicationProtocol) { // Handles both un-configured and none selected. null, "" -> null else -> protocol } } else { super.getSelectedProtocol(sslSocket) } companion object { val isSupported: Boolean = try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/OpenJSSEPlatform.kt
if (sslSocket is org.openjsse.javax.net.ssl.SSLSocket) { when (val protocol = sslSocket.applicationProtocol) { // Handles both un-configured and none selected. null, "" -> null else -> protocol } } else { super.getSelectedProtocol(sslSocket) } companion object { val isSupported: Boolean = try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RouteSelector.kt
else -> addresses } for (inetAddress in orderedAddresses) { mutableInetSocketAddresses += InetSocketAddress(inetAddress, socketPort) } } } /** A set of selected Routes. */ class Selection(val routes: List<Route>) { private var nextRouteIndex = 0 operator fun hasNext(): Boolean = nextRouteIndex < routes.size operator fun next(): 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) -
docs/changelogs/changelog_4x.md
`okhttp-tls` module. * Upgrade: [Kotlin 1.3.71][kotlin_1_3_71]. ## Version 4.5.0 _2020-04-06_ **This release fixes a severe bug where OkHttp incorrectly detected and recovered from unhealthy connections.** Stale or canceled connections were incorrectly attempted when they shouldn't have been, leading to rare cases of infinite retries. Please upgrade to this release!
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-sse/src/main/kotlin/okhttp3/sse/internal/ServerSentEventReader.kt
*/ @Throws(IOException::class) fun processNextEvent(): Boolean { var id = lastId var type: String? = null val data = Buffer() while (true) { when (source.select(options)) { in 0..2 -> { completeEvent(id, type, data) return true } in 3..4 -> { source.readData(data) } in 5..7 -> {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.3K bytes - Viewed (0) -
okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/SimpleIdnaMappingTable.kt
skipWhitespace() val type = select(optionsType) when (type) { TYPE_DEVIATION, TYPE_MAPPED, TYPE_DISALLOWED_STD3_MAPPED -> { skipWhitespace() if (readByte() != ';'.code.toByte()) throw IOException("expected ';'") // Like "0061" or "0031 2044 0034". while (true) { skipWhitespace() when (select(optionsDelimiter)) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.8K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/FakeProxySelector.kt
class FakeProxySelector : ProxySelector() { val proxies: MutableList<Proxy> = mutableListOf() fun addProxy(proxy: Proxy): FakeProxySelector { proxies.add(proxy) return this } override fun select(uri: URI): List<Proxy> { // Don't handle 'socket' schemes, which the RI's Socket class may request (for SOCKS). return if (uri.scheme == "http" || uri.scheme == "https") proxies else listOf(Proxy.NO_PROXY) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
* (unless they were already returned). * * The iterator supports [MutableIterator.remove]. Removing a URL from the iterator evicts the * corresponding response from the cache. Use this to evict selected responses. */ @Throws(IOException::class) fun urls(): MutableIterator<String> { return object : MutableIterator<String> { private val delegate: MutableIterator<DiskLruCache.Snapshot> = cache.snapshots()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 26.8K bytes - Viewed (0)