Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 49 for intercepted (0.06 seconds)

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

  1. okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt

          client
            .newBuilder()
            .addNetworkInterceptor(
              Interceptor { chain: Interceptor.Chain ->
                ifNoneMatch.compareAndSet(null, chain.request().header("If-None-Match"))
                chain.proceed(chain.request())
              },
            ).build()
    
        // Confirm the value is cached and intercepted.
        assertThat(get(url).body.string()).isEqualTo("A")
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Mar 20 09:13:37 GMT 2026
    - 121K bytes
    - Click Count (0)
  2. docs/fr/docs/tutorial/dependencies/dependencies-with-yield.md

    Si vous souhaitez intercepter des exceptions et créer une réponse personnalisée en fonction de cela, créez un [Gestionnaire d'exceptions personnalisé](../handling-errors.md#install-custom-exception-handlers).
    
    ## Utiliser des dépendances avec `yield` et `except` { #dependencies-with-yield-and-except }
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:37:13 GMT 2026
    - 13.9K bytes
    - Click Count (0)
  3. android/guava-testlib/test/com/google/common/collect/testing/MapTestSuiteBuilderTests.java

          @SuppressWarnings("unchecked")
          Map<String, String> proxy =
              Reflection.newProxy(Map.class, new CheckSetUpInvocationHandler(map, setUpRan));
          return proxy;
        }
      }
    
      /**
       * Intercepts calls to a {@code Map} to check that {@code setUpRan} is true when they happen. Then
       * forwards the calls to the underlying {@code Map}.
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 11.2K bytes
    - Click Count (0)
  4. guava-testlib/test/com/google/common/collect/testing/MapTestSuiteBuilderTests.java

          @SuppressWarnings("unchecked")
          Map<String, String> proxy =
              Reflection.newProxy(Map.class, new CheckSetUpInvocationHandler(map, setUpRan));
          return proxy;
        }
      }
    
      /**
       * Intercepts calls to a {@code Map} to check that {@code setUpRan} is true when they happen. Then
       * forwards the calls to the underlying {@code Map}.
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 11.6K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java

        assertFalse(Thread.interrupted());
        try {
          delayedFuture.get(20000, MILLISECONDS);
          fail("expected to be interrupted");
        } catch (InterruptedException expected) {
        } catch (TimeoutException e) {
          throw new RuntimeException(e);
        }
    
        // we were interrupted, but it's been cleared now
        assertFalse(Thread.interrupted());
    
        assertFalse(sleeper.completed);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 8.9K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java

        assertFalse(Thread.interrupted());
        try {
          delayedFuture.get(20000, MILLISECONDS);
          fail("expected to be interrupted");
        } catch (InterruptedException expected) {
        } catch (TimeoutException e) {
          throw new RuntimeException(e);
        }
    
        // we were interrupted, but it's been cleared now
        assertFalse(Thread.interrupted());
    
        assertFalse(sleeper.completed);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 8.9K bytes
    - Click Count (0)
  7. guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

              assertThrows(RuntimeException.class, () -> GcFinalization.await(latch));
          assertWrapsInterruptedException(expected);
        } finally {
          interruptenator.shutdown();
          Thread.interrupted();
        }
      }
    
      public void testAwaitDone_future_interrupted_interrupted() {
        Interruptenator interruptenator = new Interruptenator(Thread.currentThread());
        try {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 16:11:48 GMT 2026
    - 8.8K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

        fakePool.execute(() -> Thread.currentThread().interrupt());
        // Run a task that expects that it is not interrupted while it is running.
        e.execute(() -> assertThat(Thread.currentThread().isInterrupted()).isFalse());
    
        // Run these together.
        fakePool.runAll();
    
        // Check that this thread has been marked as interrupted again now that the thread has been
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 10.5K bytes
    - Click Count (0)
  9. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

      /**
       * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage collector
       * as necessary to try to ensure that this will happen.
       *
       * @throws RuntimeException if timed out or interrupted while waiting
       */
      @SuppressWarnings("removal") // b/487687332
      public static void awaitDone(Future<?> future) {
        if (future.isDone()) {
          return;
        }
        long timeoutSeconds = timeoutSeconds();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 20:19:19 GMT 2026
    - 12.3K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        AtomicBoolean interrupted = new AtomicBoolean();
        // we need to use another thread because it will be interrupted and thus using
        // the current one, owned by JUnit, would make the test fail
        Thread thread =
            new Thread(
                () -> {
                  terminated.set(shutdownAndAwaitTermination(service, 1L, SECONDS));
                  interrupted.set(Thread.currentThread().isInterrupted());
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 26.1K bytes
    - Click Count (0)
Back to Top