- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 60 for Krause (0.18 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
length: Int, flags: Int, streamId: Int, ) { if (streamId == 0) throw IOException("PROTOCOL_ERROR: TYPE_DATA streamId == 0") // TODO: checkState open or half-closed (local) or raise STREAM_CLOSED val inFinished = flags and FLAG_END_STREAM != 0 val gzipped = flags and FLAG_COMPRESSED != 0 if (gzipped) { throw IOException("PROTOCOL_ERROR: FLAG_COMPRESSED without SETTINGS_COMPRESS_DATA")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 19.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/HttpUrl.kt
* These two URLs are semantically identical, but `java.net.URI` disagrees: * * * http://host:80/ * * * http://host * * Both the unnecessary port specification (`:80`) and the absent trailing slash (`/`) cause URI to * bucket the two URLs separately. This harms URI's usefulness in collections. Any application that * stores information-per-URL will need to either canonicalize manually, or suffer unnecessary * redundancy for such URLs.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 63.5K bytes - Viewed (1) -
samples/guide/src/test/kotlin/okhttp3/AllMainsTest.kt
} } catch (ite: InvocationTargetException) { if (!expectedFailure(className, ite.cause!!)) { throw ite.cause!! } } } @Suppress("UNUSED_PARAMETER") private fun expectedFailure( className: String, cause: Throwable, ): Boolean { return when (className) { "okhttp3.recipes.CheckHandshake" -> true // by design
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
cache.close() createNewCacheWithSize(10) set("a", "a", "aaa") // size 4 set("b", "bb", "bbbb") // size 6 assertThat(cache.size()).isEqualTo(10) // Cause the size to grow to 12 should evict 'A'. set("c", "c", "c") cache.flush() assertThat(cache.size()).isEqualTo(8) assertAbsent("a") assertValue("b", "bb", "bbbb") assertValue("c", "c", "c")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 75.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
*/ override fun close() { close(ErrorCode.NO_ERROR, ErrorCode.CANCEL, null) } internal fun close( connectionCode: ErrorCode, streamCode: ErrorCode, cause: IOException?, ) { this.assertThreadDoesntHoldLock() ignoreIoExceptions { shutdown(connectionCode) } var streamsToClose: Array<Http2Stream>? = null this.withLock {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
connectionUser.releaseConnectionNoEvents() } else -> null } } // If the call's connection wasn't released, reuse it. We don't call connectionAcquired() here // because we already acquired it. if (connectionUser.candidateConnection() != null) { check(toClose == null) return ReusePlan(candidate) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 12K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingSSLSocket.kt
} override fun isOutputShutdown(): Boolean { return delegate!!.isOutputShutdown } @Throws(SocketException::class) override fun setReuseAddress(reuse: Boolean) { delegate!!.reuseAddress = reuse } @Throws(SocketException::class) override fun getReuseAddress(): Boolean { return delegate!!.reuseAddress } @Throws(SocketException::class)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.9K bytes - Viewed (0) -
okhttp-testing-support/src/test/kotlin/okhttp3/OkHttpClientTestRuleTest.kt
assertFailsWith<AssertionError> { testRule.afterEach(extensionContext) }.also { expected -> assertThat(expected).hasMessage("uncaught exception thrown during test") assertThat(expected.cause!!).hasMessage("boom!") } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.7K bytes - Viewed (0) -
okhttp-brotli/src/test/java/okhttp3/brotli/BrotliInterceptorTest.kt
val failingResponse = uncompress(response) failingResponse.body.string() }.also { ioe -> assertThat(ioe).hasMessage("Brotli stream decoding failed") assertThat(ioe.cause?.javaClass?.simpleName).isEqualTo("BrotliRuntimeException") } } @Test fun testSkipUncompressNoContentResponse() { val response = response("https://httpbin.org/brotli", EMPTY) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.2K bytes - Viewed (0) -
regression-test/src/androidTest/java/okhttp/regression/LetsEncryptTest.java
HandshakeCertificates certificates = new HandshakeCertificates.Builder() .addTrustedCertificate((X509Certificate) isgCertificate) // Uncomment to allow connection to any site generally, but will cause // noticeable memory pressure in Android apps. // .addPlatformTrustedCertificates() .build();
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Nov 17 07:40:31 GMT 2020 - 6.1K bytes - Viewed (0)