- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for web (0.23 sec)
-
docs/changelogs/changelog_4x.md
compressing outbound web socket messages. Configure this with 0L to always compress outbound messages and `Long.MAX_VALUE` to never compress outbound messages. The default is 1024L which compresses messages of size 1 KiB and larger. (Inbound messages are compressed or not based on the web socket server's configuration.)
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) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
* sensitive information. */ private fun toLoggableString(): String { return ( (if (isCanceled()) "canceled " else "") + (if (forWebSocket) "web socket" else "call") + " to " + redactedUrl() ) } internal fun redactedUrl(): String = originalRequest.url.redact() inner class AsyncCall( private val responseCallback: Callback,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
import okhttp3.internal.isHealthy import okhttp3.internal.tls.OkHostnameVerifier import okhttp3.internal.ws.RealWebSocket import okio.BufferedSink import okio.BufferedSource /** * A connection to a remote web server capable of carrying 1 or more concurrent streams. * * Connections are shared in a connection pool. Accesses to the connection's state must be guarded * by holding a lock on the connection. */ class RealConnection(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
/** Non-null for client web sockets. These can be canceled. */ internal var call: Call? = null /** This task processes the outgoing queues. Call [runWriter] to after enqueueing. */ private var writerTask: Task? = null /** Null until this web socket is connected. Only accessed by the reader thread. */ private var reader: WebSocketReader? = null // All mutable web socket state is guarded by this.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
@get:JvmName("writeTimeoutMillis") val writeTimeoutMillis: Int = builder.writeTimeout /** Web socket and HTTP/2 ping interval (in milliseconds). By default pings are not sent. */ @get:JvmName("pingIntervalMillis") val pingIntervalMillis: Int = builder.pingInterval /** Web socket close timeout (in milliseconds). */ @get:JvmName("webSocketCloseTimeout")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
.build(), ) val webSocket: WebSocket = newWebSocket() clientListener.assertOpen() val server = serverListener.assertOpen() webSocket.send("Web Sockets and Events?!") serverListener.assertTextMessage("Web Sockets and Events?!") webSocket.close(1000, "") serverListener.assertClosing(1000, "") server.close(1000, "") clientListener.assertClosing(1000, "")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
CHANGELOG.md
* Fix: Don't close a `Deflater` while we're still using it to compress a web socket message. We had a severe bug where web sockets were closed on the wrong thread, which caused `NullPointerException` crashes in `Deflater`. * Fix: Don't crash after a web socket fails its connection upgrade. We incorrectly released the web socket's connections back to the pool before their resources were cleaned up.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:31:39 GMT 2024 - 21.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
* is still valid. Such responses increment both the network count and hit count. * * The best way to improve the cache hit rate is by configuring the web server to return cacheable * responses. Although this client honors all [HTTP/1.1 (RFC 7234)][rfc_7234] cache headers, it * doesn't cache partial responses. * * ## Force a Network Response *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 26.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
.isGreaterThan(message.length.toLong()) // Not compressed. assertThat(client.processNextFrame()).isTrue() client.listener.assertTextMessage(message) } /** One peer's streams, listener, and web socket in the test. */ private class TestStreams( client: Boolean, private val taskFaker: TaskFaker, private val sourcePipe: Pipe, private val sinkPipe: Pipe,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestUtilJvm.kt
* structures. * * We make such subtle calls in [okhttp3.internal.ws.MessageInflater] because we try to read a * compressed stream that is terminated in a web socket frame even though the DEFLATE stream is * not terminated. * * Use this method to create a degenerate Okio Buffer where each byte is in a separate segment of * the internal list. */ @JvmStatic
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 4.3K bytes - Viewed (0)