Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 6 of 6 for propagated (0.17 seconds)

  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. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

          client
            .newBuilder()
            .sslSocketFactory(handshakeCertificates.sslSocketFactory())
        }
      }
    
      /** Confirm that runtime exceptions thrown inside of OkHttp propagate to the caller.  */
      @Test
      fun unexpectedExceptionSync() {
        client =
          client
            .newBuilder()
            .dns { hostname: String? -> throw RuntimeException("boom!") }
            .build()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 133.3K bytes
    - Click Count (0)
  5. 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
    - 148.9K bytes
    - Click Count (0)
  6. 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