- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 126 for Reaber (0.1 sec)
-
okhttp/src/test/java/okhttp3/EventListenerTest.kt
responseBodyBytes: Matcher<Long?>?, ) { if (requestHeaderLength != null) { val responseHeadersEnd = listener.removeUpToEvent<RequestHeadersEnd>() MatcherAssert.assertThat( "request header length", responseHeadersEnd.headerLength, requestHeaderLength, ) } else { assertThat(listener.recordedEventTypes()) .doesNotContain("RequestHeadersEnd") }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 56.9K bytes - Viewed (0) -
okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsOverHttps.kt
return DnsRecordCodec.decodeAnswers(hostname, responseBytes) } } private fun buildRequest( hostname: String, type: Int, ): Request = Request.Builder().header("Accept", DNS_MESSAGE.toString()).apply { val query = DnsRecordCodec.encodeQuery(hostname, type) if (post) { url(url) .cacheUrlOverride( url.newBuilder()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Fri Mar 22 07:09:21 UTC 2024 - 9.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionReuseTest.kt
server.enqueue(MockResponse(body = "a")) server.enqueue(MockResponse(body = "b")) val requestA = Request.Builder() .url(server.url("/")) .header("Connection", "close") .build() val requestB = Request(server.url("/")) assertConnectionNotReused(requestA, requestB) } @Test fun connectionsAreNotReusedWithResponseConnectionClose() {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 12.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/UrlComponentEncodingTester.kt
encodings[codePoint] = encoding } } fun nonPrintableAscii(encoding: Encoding) = apply { encodings[ 0x0] = encoding // Null character encodings[ 0x1] = encoding // Start of Header encodings[ 0x2] = encoding // Start of Text encodings[ 0x3] = encoding // End of Text encodings[ 0x4] = encoding // End of Transmission encodings[ 0x5] = encoding // Enquiry
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 12.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/EventListener.kt
* * body ([responseBodyStart], [responseBodyEnd]) * * This nesting is typical but not strict. For example, when calls use "Expect: continue" the * request body start and end events occur within the response header events. Similarly, * [duplex calls][RequestBody.isDuplex] interleave the request and response bodies. * * Since connections may be reused, the proxy selection, DNS, and connect events may not be present
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 15.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
*/ class Http2Reader( /** Creates a frame reader with max header table size of 4096. */ private val source: BufferedSource, private val client: Boolean, ) : Closeable { private val continuation: ContinuationSource = ContinuationSource(this.source) private val hpackReader: Hpack.Reader = Hpack.Reader( source = continuation, headerTableSizeSetting = 4096, )
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 19.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Header.kt
* limitations under the License. */ package okhttp3.internal.http2 import okio.ByteString import okio.ByteString.Companion.encodeUtf8 /** HTTP header: the name is an ASCII string, but the value can be UTF-8. */ data class Header( /** Name in case-insensitive ASCII encoding. */ @JvmField val name: ByteString, /** Value in UTF-8 encoding. */ @JvmField val value: ByteString, ) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt
import okhttp3.internal.http.promisesBody import okhttp3.internal.http2.Header.Companion.RESPONSE_STATUS_UTF8 import okhttp3.internal.http2.Header.Companion.TARGET_AUTHORITY import okhttp3.internal.http2.Header.Companion.TARGET_AUTHORITY_UTF8 import okhttp3.internal.http2.Header.Companion.TARGET_METHOD import okhttp3.internal.http2.Header.Companion.TARGET_METHOD_UTF8 import okhttp3.internal.http2.Header.Companion.TARGET_PATH
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.9K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/internal/http2/Http2Server.kt
} } private fun send404( stream: Http2Stream, path: String, ) { val responseHeaders = listOf( Header(":status", "404"), Header(":version", "HTTP/1.1"), Header("content-type", "text/plain"), ) stream.writeHeaders( responseHeaders = responseHeaders, outFinished = false, flushHeaders = false, )
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketExtensions.kt
// Parse each header. for (i in 0 until responseHeaders.size) { if (!responseHeaders.name(i).equals(HEADER_WEB_SOCKET_EXTENSION, ignoreCase = true)) { continue // Not a header we're interested in. } val header = responseHeaders.value(i) // Parse each extension. var pos = 0 while (pos < header.length) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 8.1K bytes - Viewed (0)