- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 124 for where (0.16 sec)
-
okhttp/src/test/java/okhttp3/CallTest.kt
} @Test fun canceledBeforeResponseReadSignalsOnFailure_HTTP_2() { enableProtocol(Protocol.HTTP_2) canceledBeforeResponseReadSignalsOnFailure() } /** * There's a race condition where the cancel may apply after the stream has already been * processed. */ @Test fun canceledAfterResponseIsDeliveredBreaksStreamButSignalsOnce() { server.enqueue(MockResponse(body = "A"))
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
Proxy.Type.DIRECT, Proxy.Type.HTTP -> route.address.socketFactory.createSocket()!! else -> Socket(route.proxy) } this.rawSocket = rawSocket // Handle the race where cancel() precedes connectSocket(). We don't want to miss a cancel. if (canceled) { throw IOException("canceled") } rawSocket.soTimeout = socketReadTimeoutMillis try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 18.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/tls/CertificateChainCleaner.kt
import okhttp3.internal.platform.Platform /** * Computes the effective certificate chain from the raw array returned by Java's built in TLS APIs. * Cleaning a chain returns a list of certificates where the first element is `chain[0]`, each * certificate is signed by the certificate that follows, and the last certificate is a trusted CA * certificate. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2K bytes - Viewed (0) -
gradlew
# options in "$@", and eventually passing that to Java. # # Where the inherited environment variables (DEFAULT_JVM_OPTS, JAVA_OPTS, # and GRADLE_OPTS) rely on word-splitting, this is performed explicitly; # see the in-line comments for details. # # There are tweaks for specific operating systems such as AIX, CygWin, # Darwin, MinGW, and NonStop. #
Shell Script - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Dec 24 09:00:26 GMT 2023 - 8.5K bytes - Viewed (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
assertThat(in2.read()).isEqualTo(-1) assertThat(server.takeRequest().sequenceNumber).isEqualTo(0) assertThat(server.takeRequest().sequenceNumber).isEqualTo(0) } @Disabled("Not actually failing where expected") @Test fun disconnectAtStart() { server.enqueue( MockResponse() .setSocketPolicy(SocketPolicy.DISCONNECT_AT_START), )
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 21.9K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestUtilJvm.kt
* 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 fun fragmentBuffer(buffer: Buffer): Buffer { // Write each byte into a new buffer, then clone it so that the segments are shared.
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) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
* if (forceCacheResponse.code() != 504) { * // The resource was cached! Show it. * } else { * // The resource was not cached. * } * ``` * * This technique works even better in situations where a stale response is better than no response. * To permit stale cached responses, use the `max-stale` directive with the maximum staleness in * seconds: * * ```java * Request request = new Request.Builder()
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/FastFallbackTest.kt
assertFailsWith<IOException> { call.execute() }.also { expected -> assertThat(expected).hasMessage("timeout") } } /** * This test reproduces a crash where OkHttp attempted to use a deferred connection when the call * already had a healthy connection. It sets up a deferred connection by stalling the IPv6
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-UtilCommon.kt
internal fun Regex.matchAtPolyfill( input: CharSequence, index: Int, ): MatchResult? { val candidate = find(input, index) ?: return null if (candidate.range.first != index) return null // Didn't match where it should have. return candidate } @JvmField val EMPTY_BYTE_ARRAY: ByteArray = ByteArray(0) /** Byte order marks. */ internal val UNICODE_BOMS = Options.of( // UTF-8. "efbbbf".decodeHex(),
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/tls/BasicCertificateChainCleaner.kt
/** * A certificate chain cleaner that uses a set of trusted root certificates to build the trusted * chain. This class duplicates the clean chain building performed during the TLS handshake. We * prefer other mechanisms where they exist, such as with * [okhttp3.internal.platform.AndroidPlatform.AndroidCertificateChainCleaner]. * * This class includes code from [Conscrypt's][Conscrypt] [TrustManagerImpl] and * [TrustedCertificateIndex]. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.8K bytes - Viewed (0)