- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 49 for intercepted (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)