- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for extensions (0.17 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
return } // Apply the extensions. If they're unacceptable initiate a graceful shut down. // TODO(jwilson): Listeners should get onFailure() instead of onClosing() + onClosed(1010). val extensions = WebSocketExtensions.parse(response.headers) this@RealWebSocket.extensions = extensions if (!extensions.isValid()) { synchronized(this@RealWebSocket) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K 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/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
newWebSocket( Request.Builder() .url(webServer.url("/")) .header("Sec-WebSocket-Extensions", "permessage-deflate") .build(), ) clientListener.assertFailure( ProtocolException::class.java, "Request header not permitted: 'Sec-WebSocket-Extensions'", ) } @Test fun webSocketAndApplicationInterceptors() { val interceptedCount = AtomicInteger()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
container-tests/build.gradle.kts
} jvmArgs( "-Dokhttp.platform=$platform", ) if (platform == "loom") { jvmArgs( "-Djdk.tracePinnedThreads=short", ) } val javaToolchains = project.extensions.getByType<JavaToolchainService>() javaLauncher.set(javaToolchains.launcherFor { languageVersion.set(JavaLanguageVersion.of(testJavaVersion)) }) } dependencies { api(projects.okhttp)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 17 14:46:34 GMT 2024 - 1.1K bytes - Viewed (0) -
okhttp-testing-support/src/test/kotlin/okhttp3/testing/PlatformRuleTest.kt
* limitations under the License. */ package okhttp3.testing import okhttp3.internal.platform.Platform import org.junit.jupiter.api.Test import org.junit.jupiter.api.extension.RegisterExtension /** * Validates which environment is used by the IDE. */ class PlatformRuleTest { @RegisterExtension @JvmField val platform = PlatformRule() @Test fun testMode() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 1.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
assertThat(client.processNextFrame()).isTrue() client.listener.assertTextMessage(message) } @Test fun messagesCompressedWhenConfigured() { val headers = headersOf("Sec-WebSocket-Extensions", "permessage-deflate") client.initWebSocket(random, responseHeaders = headers) server.initWebSocket(random, responseHeaders = headers) val message = repeat('a', RealWebSocket.DEFAULT_MINIMUM_DEFLATE_SIZE.toInt())
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
taskRunner = taskRunner, originalRequest = request, listener = listener, random = Random(), pingIntervalMillis = pingIntervalMillis.toLong(), // extensions is always null for clients: extensions = null, minimumDeflateSize = minWebSocketMessageToCompress, webSocketCloseTimeout = webSocketCloseTimeout.toLong(), ) webSocket.connect(this) return webSocket
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) -
CHANGELOG.md
========== ## Version 4.x See [4.x Change log](https://square.github.io/okhttp/changelogs/changelog_4x/) for the stable version changelogs. ## Version 5.0.0-alpha.14 _2024-04-17_ * Breaking: Move coroutines extensions to okhttp3.coroutines. Previously this artifact shared the `okhttp3` package name with our core module, which is incompatible with the Java Platform Module System.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:31:39 GMT 2024 - 21.4K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
taskRunner = taskRunner, originalRequest = fancyRequest, listener = webSocketResponse.webSocketListener!!, random = SecureRandom(), pingIntervalMillis = 0, extensions = WebSocketExtensions.parse(webSocketResponse.headers), // Compress all messages if compression is enabled. minimumDeflateSize = 0L, webSocketCloseTimeout = RealWebSocket.CANCEL_AFTER_CLOSE_MILLIS,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
okhttp-tls/src/test/java/okhttp3/tls/HandshakeCertificatesTest.kt
import okhttp3.testing.PlatformRule import okio.ByteString.Companion.toByteString import org.junit.jupiter.api.AfterEach import org.junit.jupiter.api.BeforeEach import org.junit.jupiter.api.Test import org.junit.jupiter.api.extension.RegisterExtension class HandshakeCertificatesTest { @RegisterExtension var platform = PlatformRule() private lateinit var executorService: ExecutorService private var serverSocket: ServerSocket? = null
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 7.1K bytes - Viewed (0)