Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 38 for intercepted (1.26 sec)

  1. docs/works_with_okhttp.md

     * [okhttp-spring-boot](https://github.com/freefair/okhttp-spring-boot): Spring Boot starters for OkHttp
     * [okhttp-staleiferror-interceptor](https://github.com/PeelTechnologies/okhttp-staleiferror-interceptor/): serve stale responses when the server isn’t reachable.
     * [okhttp-stats](https://github.com/flipkart-incubator/okhttp-stats): Get stats like average network speed.
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 26 07:59:38 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  2. 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 {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 08 17:02:07 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  3. CHANGELOG.md

    _2025-10-30_
    
     *  New: Add tags to `Call`, including computable tags. Use this to attach application-specific
        metadata to a `Call` in an `EventListener` or `Interceptor`. The tag can be read in any other
        `EventListener` or `Interceptor`.
    
        ```kotlin
          override fun intercept(chain: Interceptor.Chain): Response {
            chain.call().tag(MyAnalyticsTag::class) {
              MyAnalyticsTag(...)
            }
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 05 16:02:59 UTC 2025
    - 36.2K bytes
    - Viewed (2)
  4. android/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 {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 08 17:02:07 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  5. fess-crawler/src/test/java/org/codelibs/fess/crawler/interval/impl/HostIntervalControllerTest.java

                for (final Future<Integer> future : futures) {
                    future.get();
                }
            } catch (final InterruptedException e) {
                // Interrupted while waiting
            } catch (final ExecutionException e) {
                // Execution failed
            } finally {
                executor.shutdown();
                try {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java

                    }
                    parentThread.join(millis);
                } catch (final InterruptedException e) {
                    logger.warn("Crawler thread was interrupted while waiting for termination: thread={}, sessionId={}", parentThread.getName(),
                            crawlerContext.sessionId, e);
                    Thread.currentThread().interrupt();
                }
            }
        }
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 17K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        AtomicBoolean terminated = new AtomicBoolean();
        // we need to keep this in a flag because t.isInterrupted() returns false after t.join()
        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(
                new Runnable() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 26.5K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        AtomicBoolean terminated = new AtomicBoolean();
        // we need to keep this in a flag because t.isInterrupted() returns false after t.join()
        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(
                new Runnable() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 26.5K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/helper/DataIndexHelper.java

             * Interrupted exceptions are caught and logged at debug level.
             */
            public void awaitTermination() {
                try {
                    join();
                } catch (final InterruptedException e) {
                    if (logger.isDebugEnabled()) {
                        logger.debug("Interrupted.", e);
                    }
                }
            }
    
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 19K bytes
    - Viewed (0)
  10. android-test/build.gradle.kts

        )
      }
    
      if (androidBuild) {
        sourceSets["androidTest"].java.srcDirs(
          "../okhttp-brotli/src/test/java",
          "../okhttp-dnsoverhttps/src/test/java",
          "../okhttp-logging-interceptor/src/test/java",
          "../okhttp-sse/src/test/java"
        )
      }
    
      compileOptions {
        targetCompatibility(JavaVersion.VERSION_11)
        sourceCompatibility(JavaVersion.VERSION_11)
      }
    
      testOptions {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Nov 21 12:33:41 UTC 2025
    - 3.9K bytes
    - Viewed (2)
Back to top