- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 62 for sset (0.15 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Settings.kt
return if (bit and set != 0) values[INITIAL_WINDOW_SIZE] else DEFAULT_INITIAL_WINDOW_SIZE } fun clear() { set = 0 values.fill(0) } operator fun set( id: Int, value: Int, ): Settings { if (id < 0 || id >= values.size) { return this // Discard unknown settings. } val bit = 1 shl id set = set or bit values[id] = value
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.8K bytes - Viewed (0) -
build.gradle.kts
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:32:42 GMT 2024 - 8.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
frameHeader( streamId = 0, length = settings.size() * 6, type = TYPE_SETTINGS, flags = FLAG_NONE, ) for (i in 0 until Settings.COUNT) { if (!settings.isSet(i)) continue val id = when (i) { 4 -> 3 // SETTINGS_MAX_CONCURRENT_STREAMS renumbered. 7 -> 4 // SETTINGS_INITIAL_WINDOW_SIZE renumbered. else -> i }
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/ConnectionSpecTest.kt
.allEnabledTlsVersions() .build() val set: MutableSet<Any> = CopyOnWriteArraySet() assertThat(set.add(ConnectionSpec.MODERN_TLS)).isTrue() assertThat(set.add(ConnectionSpec.COMPATIBLE_TLS)).isTrue() assertThat(set.add(ConnectionSpec.CLEARTEXT)).isTrue() assertThat(set.add(allTlsVersions)).isTrue() assertThat(set.add(allCipherSuites)).isTrue() allCipherSuites.hashCode()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 14.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/HttpUrl.kt
import okhttp3.internal.url.FRAGMENT_ENCODE_SET import okhttp3.internal.url.FRAGMENT_ENCODE_SET_URI import okhttp3.internal.url.PASSWORD_ENCODE_SET import okhttp3.internal.url.PATH_SEGMENT_ENCODE_SET import okhttp3.internal.url.PATH_SEGMENT_ENCODE_SET_URI import okhttp3.internal.url.QUERY_COMPONENT_ENCODE_SET import okhttp3.internal.url.QUERY_COMPONENT_ENCODE_SET_URI import okhttp3.internal.url.QUERY_COMPONENT_REENCODE_SET
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 63.5K bytes - Viewed (1) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceRecorder.kt
import okhttp3.Response import okhttp3.internal.platform.Platform import okhttp3.internal.platform.Platform.Companion.get import okhttp3.sse.EventSource import okhttp3.sse.EventSourceListener class EventSourceRecorder : EventSourceListener() { private val events = LinkedBlockingDeque<Any>() private var cancel = false fun enqueueCancel() { cancel = true } override fun onOpen( eventSource: EventSource,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.1K bytes - Viewed (0) -
docs/changelogs/changelog_3x.md
for DNS offers better security and potentially better performance. This feature is a preview: the API is subject to change. * New: `okhttp-sse` is an early preview of Server-Sent Events (SSE). This feature is incomplete and is only suitable for experimental use. * New: MockWebServer now supports client authentication (mutual TLS). Call `requestClientAuth()`
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 14:55:54 GMT 2022 - 50.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt
data.write("ca00".decodeHex()) // Empty pong, flag 1 set. assertFailsWith<ProtocolException> { clientReader.processNextFrame() }.also { expected -> assertThat(expected.message).isEqualTo("Unexpected rsv1 flag") } } @Test fun reservedFlag1IsUnsupportedForControlFrames() { data.write("ca00".decodeHex()) // Empty pong, flag 1 set. assertFailsWith<ProtocolException> {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 14.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/Jdk8WithJettyBootPlatform.kt
AlpnProvider(names), ) putMethod.invoke(null, sslSocket, alpnProvider) } catch (e: InvocationTargetException) { throw AssertionError("failed to set ALPN", e) } catch (e: IllegalAccessException) { throw AssertionError("failed to set ALPN", e) } } override fun afterHandshake(sslSocket: SSLSocket) { try { removeMethod.invoke(null, sslSocket)
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/connection/RouteSelector.kt
} /** * Returns true if there's another set of routes to attempt. Every address has at least one route. */ operator fun hasNext(): Boolean = hasNextProxy() || postponedRoutes.isNotEmpty() @Throws(IOException::class) operator fun next(): Selection { if (!hasNext()) throw NoSuchElementException() // Compute the next set of routes to attempt. val routes = mutableListOf<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)