- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 136 for Reaber (0.41 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/internal/RecordingOkAuthenticator.kt
responses += response routes += route if (!schemeMatches(response) || credential == null) return null val header = when (response.code) { 407 -> "Proxy-Authorization" else -> "Authorization" } return response.request.newBuilder() .addHeader(header, credential) .build() } private fun schemeMatches(response: Response): Boolean { if (scheme == null) return true
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.7K bytes - Viewed (0) -
docs/contribute/concurrency.md
The reader thread must never run application-layer code. Otherwise one slow stream can hold up the entire connection.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Feb 06 16:35:36 UTC 2022 - 7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
val proxyConnectRequest = Request.Builder() .url(route.address.url) .method("CONNECT", null) .header("Host", route.address.url.toHostHeader(includeDefaultPort = true)) .header("Proxy-Connection", "Keep-Alive") // For HTTP/1.0 proxies like Squid. .header("User-Agent", USER_AGENT) .build() val fakeAuthChallengeResponse = Response.Builder()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 12K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Settings.kt
* uses 10 MiB). */ const val DEFAULT_INITIAL_WINDOW_SIZE = 65535 /** HTTP/2: Size in bytes of the table used to decode the sender's header blocks. */ const val HEADER_TABLE_SIZE = 1 /** HTTP/2: The peer must not send a PUSH_PROMISE frame when this is 0. */ const val ENABLE_PUSH = 2 /** Sender's maximum number of concurrent streams. */
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.8K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/ServerSentEventIteratorTest.kt
} override fun onRetryChange(timeMs: Long) { callbacks.add(timeMs) } } val buffer = Buffer().writeUtf8(source) val reader = ServerSentEventReader(buffer, callback) while (reader.processNextEvent()) { } assertThat(buffer.size, "Unconsumed buffer: ${buffer.readUtf8()}") .isEqualTo(0) }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
// Make a range request. val request = Request.Builder() .url(server.url("/")) .header("Range", "bytes=0-") .build() val call = client.newCall(request) // The response is not decompressed. val response = call.execute() assertThat(response.header("Content-Encoding")).isEqualTo("gzip") assertThat(response.body.source().readByteString()).isEqualTo(
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 142.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-HeadersCommon.kt
require(name.isNotEmpty()) { "name is empty" } for (i in name.indices) { val c = name[i] require(c in '\u0021'..'\u007e') { "Unexpected char 0x${c.charCode()} at $i in header name: $name" } } } internal fun headersCheckValue( value: String, name: String, ) { for (i in value.indices) { val c = value[i]
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/MessageInflater.kt
class MessageInflater( private val noContextTakeover: Boolean, ) : Closeable { private val deflatedBytes = Buffer() private val inflater = Inflater( // nowrap (omits zlib header): true, ) private val inflaterSource = InflaterSource(deflatedBytes, inflater) /** Inflates [buffer] in place as described in RFC 7692 section 7.2.2. */ @Throws(IOException::class)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/MultipartBody.kt
fun create( headers: Headers?, body: RequestBody, ): Part { require(headers?.get("Content-Type") == null) { "Unexpected header: Content-Type" } require(headers?.get("Content-Length") == null) { "Unexpected header: Content-Length" } return Part(headers, body) } @JvmStatic fun createFormData( name: String, value: String,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.9K bytes - Viewed (0) -
samples/compare/src/test/kotlin/okhttp3/compare/JettyHttpClientTest.kt
client.stop() } @Test fun get(server: MockWebServer) { server.enqueue(MockResponse(body = "hello, Jetty HTTP Client")) val request = client.newRequest(server.url("/").toUri()) .header("Accept", "text/plain") val response = request.send() assertThat(response.status).isEqualTo(200) assertThat(response.contentAsString).isEqualTo("hello, Jetty HTTP Client") val recorded = server.takeRequest()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2K bytes - Viewed (0)