Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for exhaust (0.03 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt

            .url(server.url("/"))
            .method(method, null)
            .build()
        val response = client.newCall(request).execute()
        assertThat(response.code).isEqualTo(expectedResponseCode)
    
        // Exhaust the content stream.
        response.body.string()
        val cached = cacheGet(cache, request)
        if (shouldWriteToCache) {
          assertThat(cached).isNotNull()
          cached!!.body.close()
        } else {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 113.6K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

        assertThat(response.header("h2")).isEqualTo("v2")
        assertThat(source.readUtf8(5)).isEqualTo("Hello")
        assertThat(source.readUtf8(7)).isEqualTo("Bonjour")
        assertThat(source.exhausted()).isTrue()
        assertThat(response.trailers()).isEqualTo(headersOf("trailers", "boom"))
      }
    
      @Test
      fun clientReadsHeadersDataTrailersHttp2() {
        platform.assumeHttp2Support()
        server.enqueue(
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 146.6K bytes
    - Viewed (0)
  3. okhttp/src/androidMain/baseline-prof.txt

    HSPLokio/AsyncTimeout;-><clinit>()V
    HSPLokio/AsyncTimeout;-><init>()V
    HSPLokio/AsyncTimeout;->enter()V
    HSPLokio/AsyncTimeout;->exit()Z
    HSPLokio/Buffer;-><init>()V
    HSPLokio/Buffer;->exhausted()Z
    HSPLokio/Buffer;->getByte(J)B
    HSPLokio/Buffer;->indexOfElement(Lokio/ByteString;)J
    HSPLokio/Buffer;->rangeEquals(JLokio/ByteString;)Z
    HSPLokio/Buffer;->read(Lokio/Buffer;J)J
    HSPLokio/Buffer;->read([BII)I
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Dec 30 23:28:56 UTC 2024
    - 127.9K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

        assertThat(URLConnection.getDefaultRequestProperty("X-setDefaultRequestProperty")).isNull()
      }
    
      /**
       * Reads `count` characters from the stream. If the stream is exhausted before `count`
       * characters can be read, the remaining characters are returned and the stream is closed.
       */
      private fun readAscii(
        inputStream: InputStream,
        count: Int,
      ): String {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jun 21 20:36:35 UTC 2025
    - 133.2K bytes
    - Viewed (0)
Back to top