Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 219 for intercept (0.05 seconds)

  1. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        assertThat(expected)
            .hasMessageThat()
            .isEqualTo("I bet you didn't think Thread.interrupt could throw");
        /*
         * We need to wait for the runner to exit. It used to be that the runner would get stuck in the
         * busy loop when interrupt threw.
         *
         * While we're at it, we confirm that the interrupt happened as expected.
         */
        ExecutionException fromRunInterruptibly =
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/collect/GeneralRangeTest.java

            range.intersect(GeneralRange.range(ORDERING, 1, OPEN, 3, OPEN)));
      }
    
      public void testIntersectNonOverlappingRange() {
        GeneralRange<Integer> range = GeneralRange.range(ORDERING, 2, OPEN, 4, CLOSED);
        assertTrue(range.intersect(GeneralRange.range(ORDERING, 5, CLOSED, 6, CLOSED)).isEmpty());
        assertTrue(range.intersect(GeneralRange.range(ORDERING, 1, OPEN, 2, OPEN)).isEmpty());
      }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 8.4K bytes
    - Click Count (0)
  3. okhttp-logging-interceptor/README.md

    Logging Interceptor
    ===================
    
    An [OkHttp interceptor][interceptors] which logs HTTP request and response data.
    
    ```java
    HttpLoggingInterceptor logging = new HttpLoggingInterceptor();
    logging.setLevel(Level.BASIC);
    OkHttpClient client = new OkHttpClient.Builder()
      .addInterceptor(logging)
      .build();
    ```
    
    You can change the log level at any time by calling `setLevel()`.
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Oct 30 21:39:59 GMT 2025
    - 1.3K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/CancelTest.kt

    @Timeout(30)
    @Tag("Slow")
    @Burst
    class CancelTest(
      private val cancelMode: CancelMode = INTERRUPT,
      private val connectionType: ConnectionType = H2,
    ) {
      @JvmField @RegisterExtension
      val platform = PlatformRule()
    
      private var threadToCancel: Thread? = null
    
      enum class CancelMode {
        CANCEL,
        INTERRUPT,
      }
    
      enum class ConnectionType {
        H2,
        HTTPS,
        HTTP,
      }
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

            }
          } else {
            Thread.yield();
          }
          state = get();
        }
        if (restoreInterruptedBit) {
          currentThread.interrupt();
        }
        /*
         * TODO(cpovirk): Clear interrupt status here? We currently don't, which means that an interrupt
         * before, during, or after runInterruptibly() (unless it produced an InterruptedException
         * caught above) can linger and affect listeners.
         */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 10K bytes
    - Click Count (0)
  6. android/guava-tests/test/com/google/common/collect/GeneralRangeTest.java

            range.intersect(GeneralRange.range(ORDERING, 1, OPEN, 3, OPEN)));
      }
    
      public void testIntersectNonOverlappingRange() {
        GeneralRange<Integer> range = GeneralRange.range(ORDERING, 2, OPEN, 4, CLOSED);
        assertTrue(range.intersect(GeneralRange.range(ORDERING, 5, CLOSED, 6, CLOSED)).isEmpty());
        assertTrue(range.intersect(GeneralRange.range(ORDERING, 1, OPEN, 2, OPEN)).isEmpty());
      }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 8.4K bytes
    - Click Count (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/OkHttpClientTest.kt

        }
      }
    
      @Test fun clonedInterceptorsListsAreIndependent() {
        val interceptor =
          Interceptor { chain: Interceptor.Chain ->
            chain.proceed(chain.request())
          }
        val original = clientTestRule.newClient()
        original
          .newBuilder()
          .addInterceptor(interceptor)
          .addNetworkInterceptor(interceptor)
          .build()
        assertThat(original.interceptors.size).isEqualTo(0)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Jun 18 12:28:21 GMT 2025
    - 13.4K bytes
    - Click Count (1)
  8. settings.gradle.kts

    include(":samples:slack")
    include(":samples:static-server")
    include(":samples:tlssurvey")
    include(":samples:unixdomainsockets")
    include(":container-tests")
    include(":module-tests")
    
    project(":okhttp-logging-interceptor").name = "logging-interceptor"
    
    val androidHome = System.getenv("ANDROID_HOME")
    val localProperties = Properties().apply {
      val file = rootProject.projectDir.resolve("local.properties")
      if (file.exists()) {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Oct 11 09:17:37 GMT 2025
    - 2K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

         */
        fun interceptors(): MutableList<Interceptor> = interceptors
    
        fun addInterceptor(interceptor: Interceptor) =
          apply {
            interceptors += interceptor
          }
    
        @JvmName("-addInterceptor") // Prefix with '-' to prevent ambiguous overloads from Java.
        inline fun addInterceptor(crossinline block: (chain: Interceptor.Chain) -> Response) =
          addInterceptor(Interceptor { chain -> block(chain) })
    
        /**
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Oct 07 21:55:03 GMT 2025
    - 51.4K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

     * @author Chris Povirk
     */
    @NullUnmarked
    final class InterruptionUtil {
      private static final Logger logger = Logger.getLogger(InterruptionUtil.class.getName());
    
      /** Runnable which will interrupt the target thread repeatedly when run. */
      private static final class Interruptenator implements Runnable {
        private final long everyMillis;
        private final Thread interruptee;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Aug 10 19:54:19 GMT 2025
    - 4.5K bytes
    - Click Count (0)
Back to Top