Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 5 of 5 for addListener (0.08 seconds)

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

       * }
       *
       * <p>When selecting an executor, note that {@code directExecutor} is dangerous in some cases. See
       * the discussion in the {@link ListenableFuture#addListener} documentation. All its warnings
       * about heavyweight listeners are also applicable to heavyweight functions passed to this method.
       *
       * <p>After calling this method, you may not call {@link #finishToFuture()}, {@link
    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)
  2. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

      public void testTransform_stackOverflow() throws Exception {
        SettableFuture<Object> input = SettableFuture.create();
        ListenableFuture<Object> output = transform(input, identity(), directExecutor());
        output.addListener(
            () -> {
              throw new StackOverflowError();
            },
            directExecutor());
        assertThrows(StackOverflowError.class, () -> input.set("foo"));
      }
    
    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. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

      public void testTransform_stackOverflow() throws Exception {
        SettableFuture<Object> input = SettableFuture.create();
        ListenableFuture<Object> output = transform(input, identity(), directExecutor());
        output.addListener(
            () -> {
              throw new StackOverflowError();
            },
            directExecutor());
        assertThrows(StackOverflowError.class, () -> input.set("foo"));
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/cache/LocalCache.java

            LoadingValueReference<K, V> loadingValueReference,
            CacheLoader<? super K, V> loader) {
          ListenableFuture<V> loadingFuture = loadingValueReference.loadFuture(key, loader);
          loadingFuture.addListener(
              () -> {
                try {
                  getAndRecordStats(key, hash, loadingValueReference, loadingFuture);
                } catch (Throwable t) {
    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)
  5. guava/src/com/google/common/cache/LocalCache.java

            LoadingValueReference<K, V> loadingValueReference,
            CacheLoader<? super K, V> loader) {
          ListenableFuture<V> loadingFuture = loadingValueReference.loadFuture(key, loader);
          loadingFuture.addListener(
              () -> {
                try {
                  getAndRecordStats(key, hash, loadingValueReference, loadingFuture);
                } catch (Throwable t) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 148.9K bytes
    - Click Count (0)
Back to Top