- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for Tiller (0.17 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
override fun request(): Request = originalRequest /** * Immediately closes the socket connection if it's currently held. Use this to interrupt an * in-flight request from any thread. It's the caller's responsibility to close the request body * and response body streams; otherwise resources may be leaked. * * This method is safe to be called concurrently, but provides limited guarantees. If a transport
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
// These properties are guarded by [lock]. /** * If true, no new exchanges can be created on this connection. It is necessary to set this to * true when removing a connection from the pool; otherwise a racing caller might get it from the * pool when it shouldn't. Symmetrically, this must always be checked before returning a * connection from the pool. * * Once true this is always true. Guarded by this. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/Platform.kt
fun get(): Platform = platform fun resetForTests(platform: Platform = findPlatform()) { this.platform = platform } fun alpnProtocolNames(protocols: List<Protocol>) = protocols.filter { it != Protocol.HTTP_1_0 }.map { it.toString() } // This explicit check avoids activating in Android Studio with Android specific classes // available when running plugins inside the IDE. val isAndroid: Boolean
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.8K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
sink.flush() } override fun close() { if (closed) return closed = true detachTimeout(timeout) state = STATE_READ_RESPONSE_HEADERS } } /** * An HTTP body with alternating chunk sizes and chunk bodies. It is the caller's responsibility
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Headers.kt
* the HTTP message. * * This class tracks header values line-by-line. A field with multiple comma- separated values on * the same line will be treated as a field with a single value by this class. It is the caller's * responsibility to detect and split on commas if their field permits multiple values. This * simplifies use of single-valued fields whose values routinely contain commas, such as cookies or * dates. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallHandshakeTest.kt
val handshake = makeRequest(client) assertThat(handshake.cipherSuite).isIn(*expectedModernTls13CipherSuites.toTypedArray()) // TODO: filter down to TLSv1.3 when only activated. // Probably something like // TLS_AES_128_GCM_SHA256 // TLS_AES_256_GCM_SHA384 // TLS_ECDHE_ECDSA_WITH_AES_256_GCM_SHA384
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 11.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Response.kt
* auth param in the challenge at key null. Invalid headers and challenges are ignored. * No semantic validation is done, for example that `Basic` auth must have a `realm` * auth param, this is up to the caller that interprets these challenges. */ fun challenges(): List<Challenge> { return headers.parseChallenges( when (code) { HTTP_UNAUTHORIZED -> "WWW-Authenticate"
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 15.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FastFallbackTest.kt
// In the process we made one successful connection attempt. assertThat(listener.recordedEventTypes().filter { it == "ConnectStart" }).hasSize(2) assertThat(listener.recordedEventTypes().filter { it == "ConnectFailed" }).hasSize(1) assertThat(listener.recordedEventTypes().filter { it == "ConnectEnd" }).hasSize(1) } @Test fun reachesIpv6WhenIpv4IsDown() { serverIpv4.shutdown()
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/ws/RealWebSocket.kt
* enqueue messages followed by pongs, but this sends pongs followed by messages. Pongs are always * written in the order they were enqueued. * * If a frame cannot be sent - because there are none enqueued or because the web socket is not * connected - this does nothing and returns false. Otherwise this returns true and the caller
Plain Text - Registered: Fri May 03 11:42:14 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
* This is typical for Java but atypical for HTTP/2. This is motivated by exception transparency: * an [IOException] that was triggered by a certain caller can be caught and handled by that caller. */ @Suppress("NAME_SHADOWING") class Http2Connection internal constructor(builder: Builder) : Closeable { internal val lock: ReentrantLock = ReentrantLock()
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)