- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 150 for Messages (0.17 sec)
-
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
.build(), ) val response = getResponse(newRequest("/")) assertThat(response.protocol).isEqualTo(Protocol.HTTP_1_1) } /** For example, empty Protobuf RPC messages end up as a zero-length POST. */ @Test fun zeroLengthPost() { zeroLengthPayload("POST") } @Test fun zeroLengthPost_HTTP_2() { enableProtocol(Protocol.HTTP_2)
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) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
val statusLine = StatusLine.parse(headersReader.readLine()) val responseBuilder = Response.Builder() .protocol(statusLine.protocol) .code(statusLine.code) .message(statusLine.message) .headers(headersReader.readHeaders()) .trailers { error("trailers not available") } return when { expectContinue && statusLine.code == HTTP_CONTINUE -> { null
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) -
samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt
if (verbose) { println(record.message) println(record.parameters[0]) } // JSSE logs additional messages as parameters that are not referenced in the log message. val parameter = parameters[0] as String if (message == "Produced ClientHello handshake message") {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.7K bytes - Viewed (1) -
samples/slack/src/main/java/okhttp3/slack/RtmSession.java
@Override public synchronized void onOpen(WebSocket webSocket, Response response) { System.out.println("onOpen: " + response); } // TOOD(jwilson): decode incoming messages and dispatch them somewhere. @Override public void onMessage(WebSocket webSocket, String text) { System.out.println("onMessage: " + text); }
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Nov 19 20:16:58 GMT 2016 - 2.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketWriterTest.kt
}.also { expected -> assertThat(expected.message).isEqualTo("Code must be in range [1000,5000): 98724976") } } @Test fun closeReservedThrows() { assertFailsWith<IllegalArgumentException> { clientWriter.writeClose(1005, "Hello".encodeUtf8()) }.also { expected -> assertThat(expected.message).isEqualTo("Code 1005 is reserved and may not be used.") } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.3K bytes - Viewed (0) -
okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt
} fun interface Logger { fun log(message: String) companion object { /** A [Logger] defaults output appropriate for the current platform. */ @JvmField val DEFAULT: Logger = DefaultLogger() private class DefaultLogger : Logger { override fun log(message: String) { Platform.get().log(message) } } } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 09:14:38 GMT 2024 - 11.2K bytes - Viewed (1) -
okhttp-tls/src/test/java/okhttp3/tls/HeldCertificateTest.kt
fail<Any>() } catch (expected: IllegalArgumentException) { assertThat(expected.message).isEqualTo("string does not include a private key") } try { decode(pkcs8Pem) fail<Any>() } catch (expected: IllegalArgumentException) { assertThat(expected.message).isEqualTo("string does not include a certificate") } try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 22.5K bytes - Viewed (0) -
okhttp-hpacktests/src/test/java/okhttp3/internal/http2/HpackDecodeTestBase.kt
* 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) -
okhttp/src/main/kotlin/okhttp3/internal/platform/Platform.kt
connectTimeout: Int, ) { socket.connect(address, connectTimeout) } open fun log( message: String, level: Int = INFO, t: Throwable? = null, ) { val logLevel = if (level == WARN) Level.WARNING else Level.INFO logger.log(logLevel, message, t) } open fun isCleartextTrafficPermitted(hostname: String): Boolean = true /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.8K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/ResponseBodyJvmTest.kt
return Buffer().writeUtf8("hello") } } assertFailsWith<IOException> { body.bytes() }.also { expected -> assertThat(expected.message).isEqualTo( "Content-Length (10) and stream length (5) disagree", ) } } @Test fun bytesThrowsMoreThanIntMaxValue() { val body: ResponseBody =
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)