Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for extensions (0.17 sec)

  1. 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)
  2. 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))
        })
    
    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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top