- Sort Score
- Num 10 results
- Language All
Results 41 - 50 of 219 for intercept (0.08 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)