Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 143 for propagate (0.08 seconds)

  1. guava-testlib/src/com/google/common/testing/ForwardingWrapperTester.java

            }
          } catch (IllegalAccessException e) {
            throw new RuntimeException(e);
          } catch (InvocationTargetException e) {
            throw Throwables.propagate(e.getCause());
          }
          assertEquals("Failed to forward to " + method, 1, called.get());
        }
    
        @Override
        public String toString() {
          return "dummy " + interfaceType.getSimpleName();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 9.1K bytes
    - Click Count (0)
  2. guava/src/com/google/common/collect/AbstractMapBasedMultimap.java

     *
     * <p>For example, the subclass could pass a {@link java.util.TreeMap} during construction, and
     * {@link #createCollection()} could return a {@link java.util.TreeSet}, in which case the
     * multimap's iterators would propagate through the keys and values in sorted order.
     *
     * <p>Keys and values may be null, as long as the underlying collection classes support null
     * elements.
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Nov 17 22:50:48 GMT 2025
    - 48.4K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        for (int i = 0; i < 100000; i++) {
          SettableFuture<String> curr = SettableFuture.create();
          prev.setFuture(curr);
          prev = curr;
        }
        // orig is the 'outermost future', this should propagate fully down the stack of futures.
        orig.cancel(true);
        assertTrue(orig.isCancelled());
        assertTrue(prev.isCancelled());
        assertTrue(prev.wasInterrupted());
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 45.2K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/collect/AbstractMapBasedMultimap.java

     *
     * <p>For example, the subclass could pass a {@link java.util.TreeMap} during construction, and
     * {@link #createCollection()} could return a {@link java.util.TreeSet}, in which case the
     * multimap's iterators would propagate through the keys and values in sorted order.
     *
     * <p>Keys and values may be null, as long as the underlying collection classes support null
     * elements.
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Aug 12 15:51:57 GMT 2025
    - 46.9K bytes
    - Click Count (0)
  5. android/guava-testlib/src/com/google/common/testing/ForwardingWrapperTester.java

            }
          } catch (IllegalAccessException e) {
            throw new RuntimeException(e);
          } catch (InvocationTargetException e) {
            throw Throwables.propagate(e.getCause());
          }
          assertEquals("Failed to forward to " + method, 1, called.get());
        }
    
        @Override
        public String toString() {
          return "dummy " + interfaceType.getSimpleName();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 9.1K bytes
    - Click Count (0)
  6. 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)
  7. 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)
  8. android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java

        service.runFirstBarrier.await();
        service.runSecondBarrier.await();
        assertThrows(CancellationException.class, () -> future.get());
        // An execution exception holds a runtime exception (from throwables.propagate) that holds our
        // original exception.
        assertEquals(service.runException, service.failureCause());
        assertEquals(Service.State.FAILED, service.state());
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 22.8K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java

        service.runFirstBarrier.await();
        service.runSecondBarrier.await();
        assertThrows(CancellationException.class, () -> future.get());
        // An execution exception holds a runtime exception (from throwables.propagate) that holds our
        // original exception.
        assertEquals(service.runException, service.failureCause());
        assertEquals(Service.State.FAILED, service.state());
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 22.8K bytes
    - Click Count (0)
  10. 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)
Back to Top