- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 36 for Graves (0.21 sec)
-
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
import okhttp3.internal.closeQuietly import okio.Buffer import okio.BufferedSource import okio.ByteString import okio.buffer import okio.source /** Replays prerecorded outgoing frames and records incoming frames. */ class MockHttp2Peer : Closeable { private var frameCount = 0 private var client = false private val bytesOut = Buffer() private var writer = Http2Writer(bytesOut, client)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
compresses messages of size 1 KiB and larger. (Inbound messages are compressed or not based on the web socket server's configuration.) * New: Defer constructing `Inflater` and `Deflater` instances until they are needed. This saves memory if web socket compression is negotiated but not used. ## Version 4.5.0-RC1 _2020-03-17_ **This release candidate turns on web socket compression.**
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0) -
okcurl/src/main/kotlin/okhttp3/curl/Main.kt
val showHeaders: Boolean by option("-i", "--include", help = "Include protocol headers in the output").flag() val showHttp2Frames: Boolean by option("--frames", help = "Log HTTP/2 frames to STDERR").flag() val referer: String? by option("-e", "--referer", help = "Referer URL") val verbose: Boolean by option("-v", "--verbose", help = "Makes $NAME verbose during the operation").flag()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.7K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/-HostnamesCommon.kt
*/ internal fun String.toCanonicalHost(): String? { val host: String = this // If the input contains a :, it’s an IPv6 address. if (":" in host) { // If the input is encased in square braces "[...]", drop 'em. val inetAddressByteArray = ( if (host.startsWith("[") && host.endsWith("]")) { decodeIpv6(host, 1, host.length - 1) } else {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
internal val plansToCancel = CopyOnWriteArrayList<RoutePlanner.Plan>() override fun timeout(): Timeout = timeout @SuppressWarnings("CloneDoesntCallSuperClone") // We are a final type & this saves clearing state. override fun clone(): Call = RealCall(client, originalRequest, forWebSocket) override fun request(): Request = originalRequest /**
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp/src/test/java/okhttp3/HttpUrlTest.kt
'`'.code, '{'.code, '|'.code, '}'.code, ) .test(UrlComponentEncodingTester.Component.HOST) } @Test fun hostIpv6() { // Square braces are absent from host()... assertThat(parse("http://[::1]/").host).isEqualTo("::1") // ... but they're included in toString(). assertThat(parse("http://[::1]/").toString()).isEqualTo("http://[::1]/")
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 67.9K bytes - Viewed (0) -
docs/contribute/concurrency.md
So we have a dedicated thread for every socket that just reads frames and dispatches them. The reader thread must never run application-layer code. Otherwise one slow stream can hold up the entire connection.
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Feb 06 16:35:36 GMT 2022 - 7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/PushObserver.kt
* * [onHeaders] (unless canceled) * * [onData] (optional sequence of data frames) * * As a stream ID is scoped to a single HTTP/2 connection, implementations which target multiple * connections should expect repetition of stream IDs. * * Return true to request cancellation of a pushed stream. Note that this does not guarantee * future frames won't arrive on the stream ID. */ interface PushObserver { /**
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
private val pongQueue = ArrayDeque<ByteString>() /** Outgoing messages and close frames in the order they should be written. */ private val messageAndCloseQueue = ArrayDeque<Any>() /** The total size in bytes of enqueued but not yet transmitted messages. */ private var queueSize = 0L /** True if we've enqueued a close frame. No further message frames will be enqueued. */ private var enqueuedClose = false
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
close(ErrorCode.PROTOCOL_ERROR, ErrorCode.PROTOCOL_ERROR, e) } /** * Sends any initial frames and starts reading frames from the remote peer. This should be called * after [Builder.build] for all new connections. * * @param sendConnectionPreface true to send connection preface frames. This should always be true * except for in tests that don't check for a connection preface.
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0)