Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for Future (0.14 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top