- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 58 for readUtf8 (0.34 sec)
-
okhttp/src/test/java/okhttp3/SocksProxy.kt
InetAddress.getByAddress(fromSource.readByteArray(4L)) } ADDRESS_TYPE_DOMAIN_NAME -> { val domainNameLength: Int = fromSource.readByte() and 0xff val domainName = fromSource.readUtf8(domainNameLength.toLong()) // Resolve HOSTNAME_THAT_ONLY_THE_PROXY_KNOWS to localhost. when { domainName.equals(HOSTNAME_THAT_ONLY_THE_PROXY_KNOWS, ignoreCase = true) -> {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 7.7K bytes - Viewed (0) -
mockwebserver/README.md
RecordedRequest request = server.takeRequest(); assertEquals("POST /v1/chat/send HTTP/1.1", request.getRequestLine()); assertEquals("application/json; charset=utf-8", request.getHeader("Content-Type")); assertEquals("{}", request.getBody().readUtf8()); ``` #### Dispatcher By default MockWebServer uses a queue to specify a series of responses. Use a
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Dec 17 15:34:10 GMT 2023 - 5K bytes - Viewed (1) -
okhttp-sse/src/test/java/okhttp3/sse/internal/ServerSentEventIteratorTest.kt
} val buffer = Buffer().writeUtf8(source) val reader = ServerSentEventReader(buffer, callback) while (reader.processNextEvent()) { } assertThat(buffer.size, "Unconsumed buffer: ${buffer.readUtf8()}") .isEqualTo(0) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
val response1 = call1.execute() val response2 = call2.execute() assertThat(response1.body.source().readUtf8(3)).isEqualTo("ABC") assertThat(response2.body.source().readUtf8(3)).isEqualTo("GHI") assertThat(response1.body.source().readUtf8(3)).isEqualTo("DEF") assertThat(response2.body.source().readUtf8(3)).isEqualTo("JKL") assertThat(server.takeRequest().sequenceNumber).isEqualTo(0)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java
final String autoExpandReplicas) { final FessConfig fessConfig = ComponentUtil.getFessConfig(); String source = FileUtil.readUTF8(indexConfigFile); String dictionaryPath = System.getProperty("fess.dictionary.path", StringUtil.EMPTY); if (StringUtil.isNotBlank(dictionaryPath) && !dictionaryPath.endsWith("/")) {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 84.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ResponseBodyJvmTest.kt
assertThat(source.readByte() and 0xff).isEqualTo(0xef) assertThat(source.readByte() and 0xff).isEqualTo(0xbb) assertThat(source.readByte() and 0xff).isEqualTo(0xbf) assertThat(source.readUtf8()).isEqualTo("hello") } @Test fun bytesEmpty() { val body = body("") assertThat(body.bytes().size).isEqualTo(0) } @Test fun bytesSeesBom() {
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) -
okhttp/src/test/java/okhttp3/CacheTest.kt
val response1 = client.newCall(request).execute() val in1 = response1.body.source() assertThat(in1.readUtf8("I love ".length.toLong())).isEqualTo("I love ") in1.skip("puppies but hate ".length.toLong()) assertThat(in1.readUtf8("spiders".length.toLong())).isEqualTo("spiders") assertThat(in1.exhausted()).isTrue() in1.close() assertThat(cache.writeSuccessCount()).isEqualTo(1)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 108.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
connection.writePingAndAwaitPong() assertThat(stream.takeHeaders()).isEqualTo(headersOf("a", "android")) val source = stream.getSource().buffer() assertThat(source.readUtf8(5)).isEqualTo("robot") stream.getSink().close() assertThat(connection.openStreamCount()).isEqualTo(0) // Verify the peer received what was expected. val synStream = peer.takeFrame()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/UrlComponentEncodingTester.kt
for (i in 0 until utf8.size) { percentEncoded.writeUtf8("%") .writeUtf8(ByteString.of(utf8[i]).hex().uppercase()) } return percentEncoded.readUtf8() } }, /** URLs that contain this character in this component are invalid. */ FORBIDDEN, /** Hostnames that contain this character are encoded with punycode. */ PUNYCODE,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 12.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DuplexTest.kt
) call.execute().use { response -> assertThat(response.headers) .isEqualTo(headersOf("h1", "v1", "h2", "v2")) val responseBody = response.body.source() assertThat(responseBody.readUtf8(2)).isEqualTo("ok") assertThat(responseBody.exhausted()).isTrue() assertThat(response.trailers()).isEqualTo(headersOf("trailers", "boom")) } body.awaitSuccess() } @Test
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 23.9K bytes - Viewed (0)