- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for Future (0.14 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
) } client.routeDatabase.failed(failedRoute) } /** * Track a failure using this connection. This may prevent both the connection and its route from * being used for future exchanges. */ override fun trackFailure( call: RealCall, e: IOException?, ) { var noNewExchangesEvent = false lock.withLock { if (e is StreamResetException) {
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-tls/src/test/java/okhttp3/tls/HandshakeCertificatesTest.kt
import java.net.InetSocketAddress import java.net.ServerSocket import java.security.PrivateKey import java.util.concurrent.ExecutorService import java.util.concurrent.Executors import java.util.concurrent.Future import javax.net.ServerSocketFactory import javax.net.SocketFactory import javax.net.ssl.SSLSocket import okhttp3.Handshake import okhttp3.Handshake.Companion.handshake import okhttp3.TestUtil.threadFactory
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 7.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
* fail. If it is too short, slow connections will be marked as failed and extra TCP and TLS * handshakes will be required. * * The deadline is currently hardcoded. We may make this configurable in the future! */ internal fun sendDegradedPingLater() { this.withLock { if (degradedPongsReceived < degradedPingsSent) return // Already awaiting a degraded pong. degradedPingsSent++
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/test/java/okhttp3/internal/cache2/RelayTest.kt
val relay = edit(file, pipe.source, metadata, 5) val future1 = executor.submit(sourceReader(relay.newSource())) val future2 = executor.submit(sourceReader(relay.newSource())) Thread.sleep(500) sink.writeUtf8("abcdefghij") Thread.sleep(500) sink.writeUtf8("klmnopqrst") sink.close() assertThat<ByteString>(future1.get()) .isEqualTo("abcdefghijklmnopqrst".encodeUtf8())
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.1K bytes - Viewed (0) -
CHANGELOG.md
``` $ ./gradlew okcurl:nativeImage $ ./okcurl/build/graal/okcurl https://cash.app/robots.txt ``` This is our first release that supports GraalVM. Our code on this platform is less mature than JVM and Android! Please report any issues you encounter: we'll fix them urgently. * Fix: Attempt to read the response body even if the server canceled the request. This will cause
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:31:39 GMT 2024 - 21.4K bytes - Viewed (0)