Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 186 for Leader (0.18 sec)

  1. okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt

          check(type == -1)
          this.type = Http2.TYPE_SETTINGS
          this.ack = true
        }
    
        override fun headers(
          inFinished: Boolean,
          streamId: Int,
          associatedStreamId: Int,
          headerBlock: List<Header>,
        ) {
          check(type == -1)
          this.type = Http2.TYPE_HEADERS
          this.inFinished = inFinished
          this.streamId = streamId
          this.associatedStreamId = associatedStreamId
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 11 22:09:35 GMT 2024
    - 8.7K bytes
    - Viewed (0)
  2. okhttp-hpacktests/src/test/java/okhttp3/internal/http2/HpackDecodeTestBase.kt

        }
    
        /**
         * Checks if `expected` and `observed` are equal when viewed as a set and headers are
         * deduped.
         *
         * TODO: See if duped headers should be preserved on decode and verify.
         */
        private fun assertSetEquals(
          message: String,
          expected: List<Header>,
          observed: List<Header>,
        ) {
          assertThat(LinkedHashSet(observed), message)
            .isEqualTo(LinkedHashSet(expected))
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 2.2K 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/URLConnectionTest.kt

          Request.Builder()
            .url(server.url("/"))
            .header("", "A")
            .build()
        }
      }
    
      @Test
      fun emptyResponseHeaderNameIsLenient() {
        val headers = Headers.Builder()
        addHeaderLenient(headers, ":A")
        server.enqueue(
          MockResponse(
            headers = headers.build(),
            body = "body",
          ),
        )
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 131.7K bytes
    - Viewed (0)
  5. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerAdapter.kt

     */
    internal interface DerAdapter<T> {
      /** Returns true if this adapter can read [header] in a choice. */
      fun matches(header: DerHeader): Boolean
    
      /**
       * Returns a value from this adapter.
       *
       * This must always return a value, though it doesn't necessarily need to consume data from
       * [reader]. For example, if the reader's peeked tag isn't readable by this adapter, it may return
       * a default value.
       *
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  6. 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.
    
    
    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)
  7. 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)
  8. okhttp-java-net-cookiejar/src/main/kotlin/okhttp3/java/net/cookiejar/JavaNetCookieJar.kt

       */
      private fun decodeHeaderAsJavaNetCookies(
        url: HttpUrl,
        header: String,
      ): List<Cookie> {
        val result = mutableListOf<Cookie>()
        var pos = 0
        val limit = header.length
        var pairEnd: Int
        while (pos < limit) {
          pairEnd = header.delimiterOffset(";,", pos, limit)
          val equalsSign = header.delimiterOffset('=', pos, pairEnd)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 06 04:10:43 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  9. mockwebserver/src/test/java/mockwebserver3/MockResponseSniTest.kt

              url = "https://url-host.com:${server.port}/".toHttpUrl(),
              headers = headersOf("Host", "header-host"),
            ),
          )
        val response = call.execute()
        assertThat(response.isSuccessful).isTrue()
    
        val recordedRequest = server.takeRequest()
        assertThat(recordedRequest.requestUrl!!.host).isEqualTo("header-host")
        assertThat(recordedRequest.handshakeServerNames).containsExactly("url-host.com")
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 5.9K bytes
    - Viewed (1)
  10. samples/compare/src/test/kotlin/okhttp3/compare/JavaHttpClientTest.kt

        assertThat(recorded.headers["Connection"]).isEqualTo("Upgrade, HTTP2-Settings")
        if (PlatformVersion.majorVersion < 19) {
          assertThat(recorded.headers["Content-Length"]).isEqualTo("0")
        }
        assertThat(recorded.headers["HTTP2-Settings"]).isNotNull()
        assertThat(recorded.headers["Upgrade"]).isEqualTo("h2c") // HTTP/2 over plaintext!
        assertThat(recorded.headers["User-Agent"]!!).matches(Regex("Java-http-client/.*"))
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 2.7K bytes
    - Viewed (0)
Back to top