Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 35 for cancellation (1.86 sec)

  1. android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

        }
        inputFuture = null;
    
        if (localInputFuture.isCancelled()) {
          @SuppressWarnings("unchecked")
          boolean unused =
              setFuture((ListenableFuture<O>) localInputFuture); // Respects cancellation cause setting
          return;
        }
    
        /*
         * Any of the setException() calls below can fail if the output Future is cancelled between now
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Feb 20 18:03:37 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

        }
        inputFuture = null;
    
        if (localInputFuture.isCancelled()) {
          @SuppressWarnings("unchecked")
          boolean unused =
              setFuture((ListenableFuture<O>) localInputFuture); // Respects cancellation cause setting
          return;
        }
    
        /*
         * Any of the setException() calls below can fail if the output Future is cancelled between now
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Feb 20 18:03:37 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

       * Implementations must support such concurrent calls.
       *
       * Note that cancellation is best-effort and that a call may proceed normally after it has been
       * canceled. For example, happy-path events like [requestHeadersStart] and [requestHeadersEnd] may
       * occur after a call is canceled. Typically cancellation takes effect when an expensive I/O
       * operation is required.
       *
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 21:03:04 UTC 2025
    - 24.9K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

           * cycle_suppress_list.txt.
           */
          private final AbstractService service;
    
          /**
           * This lock is used to ensure safe and correct cancellation, it ensures that a new task is
           * not scheduled while a cancel is ongoing. Also it protects the currentFuture variable to
           * ensure that it is assigned atomically with being scheduled.
           */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

       */
    
      /**
       * This field encodes the current state of the future.
       *
       * <p>The valid values are:
       *
       * <ul>
       *   <li>{@code null} initial state, nothing has happened.
       *   <li>{@link Cancellation} terminal state, {@code cancel} was called.
       *   <li>{@link Failure} terminal state, {@code setException} was called.
       *   <li>{@link DelegatingToFuture} intermediate state, {@code setFuture} was called.
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 33.2K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

           * cycle_suppress_list.txt.
           */
          private final AbstractService service;
    
          /**
           * This lock is used to ensure safe and correct cancellation, it ensures that a new task is
           * not scheduled while a cancel is ongoing. Also it protects the currentFuture variable to
           * ensure that it is assigned atomically with being scheduled.
           */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  7. docs/changelogs/changelog_2x.md

        patterns. We also fixed a bug where the cache was being cleared due to a
        corrupted journal. We've added APIs to configure a request's `Cache-Control`
        headers, and to manually clear the cache.
    
     *  **Request cancellation fixes.** This update fixes a bug where synchronous
        requests couldn't be canceled by tag. This update avoids crashing when
        `onResponse()` throws an `IOException`. That failure will now be logged
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 26.6K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/AbstractFutureState.java

       */
    
      /**
       * This field encodes the current state of the future.
       *
       * <p>The valid values are:
       *
       * <ul>
       *   <li>{@code null} initial state, nothing has happened.
       *   <li>{@link Cancellation} terminal state, {@code cancel} was called.
       *   <li>{@link Failure} terminal state, {@code setException} was called.
       *   <li>{@link DelegatingToFuture} intermediate state, {@code setFuture} was called.
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

          Object result = Iterables.getOnlyElement(finalResults);
          if (result == CancellationException.class) {
            assertTrue(future.isCancelled());
            assertTrue(cancellationSuccess.get());
            // cancellation can interleave in 3 ways
            // 1. prior to setFuture
            // 2. after setFuture before set() on the future assigned
            // 3. after setFuture and set() are called but before the listener completes.
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:45:32 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/MoreExecutors.java

        }
    
        /*
         * TODO: https://github.com/google/guava/issues/2143 - In addition to overriding `execute`, also
         * override the `Future`-returning methods of `ExecutorService` to propagate cancellation from
         * our `TrustedListenableFutureTask` to a `Future` returned by the delegate executor?
         */
    
        @Override
        public final void execute(Runnable command) {
          delegate.execute(command);
        }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 08 18:55:33 UTC 2025
    - 45.2K bytes
    - Viewed (0)
Back to top