Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for Cancelling (0.04 sec)

  1. guava/src/com/google/common/util/concurrent/MoreExecutors.java

            return threadRenaming(command, nameSupplier);
          }
        };
      }
    
      /**
       * Shuts down the given executor service gradually, first disabling new submissions and later, if
       * necessary, cancelling remaining tasks.
       *
       * <p>The method takes the following steps:
       *
       * <ol>
       *   <li>calls {@link ExecutorService#shutdown()}, disabling acceptance of new submitted tasks.
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 08 18:55:33 UTC 2025
    - 45.2K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

     *
     * This class supports [asynchronous canceling][cancel]. This is intended to have the smallest
     * blast radius possible. If an HTTP/2 stream is active, canceling will cancel that stream but not
     * the other streams sharing its connection. But if the TLS handshake is still in progress then
     * canceling may break the entire connection.
     */
    class RealCall(
      val client: OkHttpClient,
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  3. CHANGELOG.md

     *  Fix: Don't crash with a `InaccessibleObjectException` when detecting the platform trust manager
        on Java 17+.
     *  Fix: Don't crash if a cookie's value is a lone double quote character.
     *  Fix: Don't crash when canceling an event source created by `EventSources.processResponse()`.
     *  New: `Cache` now has a public constructor that takes an [okio.FileSystem]. This should make it
        possible to implement decorators for cache encryption or compression.
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 05 16:02:59 UTC 2025
    - 36.2K bytes
    - Viewed (2)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

          responseDequeuedLatches[responseIndex].countDown()
          requestCanceledLatches[responseIndex].await()
          responseIndex++
          return response
        }
      }
    
      /** Make a call and canceling it as soon as it's accepted by the server.  */
      private fun callAndCancel(
        expectedSequenceNumber: Int,
        responseDequeuedLatch: CountDownLatch?,
        requestCanceledLatch: CountDownLatch?,
      ) {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Nov 01 12:18:11 UTC 2025
    - 67.4K bytes
    - Viewed (0)
Back to top