Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 62 for Weaver (3.76 sec)

  1. docs/changelogs/changelog_4x.md

        The upcoming Android Studio runs in a JVM but has classes from Android and that confused OkHttp!
    
     *  Fix: Include the header `Accept: text/event-stream` for SSE calls. This header is not added if
        the request already contains an `Accept` header.
    
     *  Fix: Don't crash with a `NullPointerException` if a server sends a close while we're sending a
        ping. OkHttp had a race condition bug.
    
    
    ## Version 4.6.0
    
    _2020-04-28_
    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)
  2. okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt

          // Read the header.
          val header = Buffer()
          fileOperator.read(0, header, FILE_HEADER_SIZE)
          val prefix = header.readByteString(PREFIX_CLEAN.size.toLong())
          if (prefix != PREFIX_CLEAN) throw IOException("unreadable cache file")
          val upstreamSize = header.readLong()
          val metadataSize = header.readLong()
    
          // Read the metadata.
    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)
  3. okhttp-tls/src/test/java/okhttp3/tls/internal/der/DerTest.kt

        val derReader = DerReader(buffer)
    
        derReader.read("test") { header ->
          assertThat(header.tag).isEqualTo(2L)
          assertThat(header.tagClass).isEqualTo(DerHeader.TAG_CLASS_CONTEXT_SPECIFIC)
          assertThat(header.length).isEqualTo(7L)
    
          derReader.read("test") { header ->
            assertThat(header.tag).isEqualTo(3L)
            assertThat(header.tagClass).isEqualTo(DerHeader.TAG_CLASS_APPLICATION)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 31.7K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/ResponseBodyJvmTest.kt

                override fun close() {
                  closed.set(true)
                  super.close()
                }
              }.buffer()
            }
          }
        val reader = body.charStream()
        assertThat(reader.read()).isEqualTo('h'.code)
        reader.close()
        assertThat(closed.get()).isTrue()
      }
    
      @Test
      fun sourceSeesBom() {
        val body = "efbbbf68656c6c6f".decodeHex().toResponseBody()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 13K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt

    import okhttp3.internal.isHealthy
    import okhttp3.internal.tls.OkHostnameVerifier
    import okhttp3.internal.ws.RealWebSocket
    import okio.BufferedSink
    import okio.BufferedSource
    
    /**
     * A connection to a remote web server capable of carrying 1 or more concurrent streams.
     *
     * Connections are shared in a connection pool. Accesses to the connection's state must be guarded
     * by holding a lock on the connection.
     */
    class RealConnection(
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/-HostnamesCommon.kt

      for (i in 0 until length) {
        val c = this[i]
        // The WHATWG Host parsing rules accepts some character codes which are invalid by
        // definition for OkHttp's host header checks (and the WHATWG Host syntax definition). Here
        // we rule out characters that would cause problems in host headers.
        if (c <= '\u001f' || c >= '\u007f') {
          return true
        }
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 11.2K bytes
    - Viewed (0)
  7. mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt

            headers = Headers.Builder()
          }
    
        /**
         * Adds [header] as an HTTP header. For well-formed HTTP [header] should contain a name followed
         * by a colon and a value.
         */
        fun addHeader(header: String) =
          apply {
            headers.add(header)
          }
    
        /**
         * Adds a new header with the name and value. This may be used to add multiple headers with the
         * same name.
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Tue Jan 23 14:31:42 GMT 2024
    - 13.3K bytes
    - Viewed (1)
  8. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt

      }
    
      @Test
      fun shutdownWithoutStart() {
        val server = MockWebServer()
        server.shutdown()
      }
    
      @Test
      fun closeViaClosable() {
        val server: Closeable = MockWebServer()
        server.close()
      }
    
      @Test
      fun shutdownWithoutEnqueue() {
        val server = MockWebServer()
        server.start()
        server.shutdown()
      }
    
      @Test
      fun portImplicitlyStarts() {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 21.9K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/CookiesTest.kt

      val clientTestRule = OkHttpClientTestRule()
      private lateinit var server: MockWebServer
      private var client = clientTestRule.newClient()
    
      @BeforeEach
      fun setUp(server: MockWebServer) {
        this.server = server
      }
    
      @Test
      fun testNetscapeResponse() {
        val cookieManager = CookieManager(null, CookiePolicy.ACCEPT_ORIGINAL_SERVER)
        client =
          client.newBuilder()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 13K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

      private var state = STATE_IDLE
      private val headersReader = HeadersReader(source)
    
      private val Response.isChunked: Boolean
        get() = "chunked".equals(header("Transfer-Encoding"), ignoreCase = true)
    
      private val Request.isChunked: Boolean
        get() = "chunked".equals(header("Transfer-Encoding"), ignoreCase = true)
    
      /**
       * Received trailers. Null unless the response body uses chunked transfer-encoding and includes
    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)
Back to top