Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 4 of 4 for propagate (0.07 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

        ListenableFuture<Bar> f2 = transformAsync(f1, function, directExecutor());
        f1.cancel(true);
        assertTrue(f2.isCancelled());
        /*
         * We might like to propagate interruption, too, but it's not clear that it matters. For now, we
         * test for the behavior that we have today.
         */
        assertFalse(((AbstractFuture<?>) f2).wasInterrupted());
      }
    
      @J2ktIncompatible
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

        ListenableFuture<Bar> f2 = transformAsync(f1, function, directExecutor());
        f1.cancel(true);
        assertTrue(f2.isCancelled());
        /*
         * We might like to propagate interruption, too, but it's not clear that it matters. For now, we
         * test for the behavior that we have today.
         */
        assertFalse(((AbstractFuture<?>) f2).wasInterrupted());
      }
    
      @J2ktIncompatible
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

           * not work. (Under Android in particular, we really should check the API Level instead of
           * probing for methods....) But it's hard to imagine how reachabilityFence in particular could
           * exist but throw, so we propagate anything that's thrown, presumably an unchecked Exception
           * or Error.
           */
          throwIfUnchecked(e.getCause());
          throw new AssertionError(e.getCause());
        }
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 101.7K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/cache/LocalCache.java

          if (result.isDone()) {
            try {
              return Uninterruptibles.getUninterruptibly(result);
            } catch (Throwable t) {
              // don't let refresh exceptions propagate; error was already logged
            }
          }
          return null;
        }
    
        /**
         * Returns a newly inserted {@code LoadingValueReference}, or null if the live value reference
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 143.5K bytes
    - Click Count (0)
Back to Top