- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for readUtf8Line (0.04 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt
assertThat(responseBody.readUtf8Line()) .isEqualTo("response B") requestBody.writeUtf8("request C\n") requestBody.flush() assertThat(responseBody.readUtf8Line()) .isEqualTo("response D") requestBody.writeUtf8("request E\n") requestBody.flush() assertThat(responseBody.readUtf8Line()) .isEqualTo("response F") requestBody.close()
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Nov 04 19:13:52 UTC 2025 - 25.8K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/ExternalHttp2Example.kt
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 1.4K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/HttpUpgradesTest.kt
sink.writeUtf8("client says hello\n") sink.flush() assertThat(source.readUtf8Line()).isEqualTo("server says hello") sink.writeUtf8("client says goodbye\n") sink.flush() assertThat(source.readUtf8Line()).isEqualTo("server says goodbye") assertThat(source.exhausted()).isTrue() } }
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Nov 04 19:13:52 UTC 2025 - 9.6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/WebPlatformUrlTestData.kt
companion object { fun load(source: BufferedSource): List<WebPlatformUrlTestData> { val list = mutableListOf<WebPlatformUrlTestData>() while (true) { val line = source.readUtf8Line() ?: break if (line.isEmpty() || line.startsWith("#")) continue var i = 0 val parts = line.split(Regex(" ")).toTypedArray() val element = WebPlatformUrlTestData()Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 3.7K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/cache/DiskLruCacheTest.kt
} } } private fun readJournalLines(): List<String> { val result = mutableListOf<String>() filesystem.read(journalFile) { while (true) { val line = readUtf8Line() ?: break result.add(line) } } return result } private fun getCleanFile( key: String, index: Int, ) = cacheDir / "$key.$index"Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat Nov 01 12:18:11 UTC 2025 - 59.4K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt
server.enqueue( MockResponse .Builder() .body("Request #2") .build(), ) val bodySource = get(server.url("/")).body.source() assertThat(bodySource.readUtf8Line()).isEqualTo("ABCDE") bodySource.use { assertFailsWith<IOException> { bodySource.readUtf8(21) } } assertThat(cache.writeAbortCount()).isEqualTo(1)
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Oct 03 17:41:45 UTC 2025 - 116.8K bytes - Viewed (0)