- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 10 for intercepted (0.07 seconds)
-
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) -
okhttp/src/androidMain/baseline-prof.txt
HSPLokhttp3/internal/http/BridgeInterceptor;-><init>(Lokhttp3/CookieJar;)V HSPLokhttp3/internal/http/BridgeInterceptor;->intercept(Lokhttp3/Interceptor$Chain;)Lokhttp3/Response; HSPLokhttp3/internal/http/CallServerInterceptor;-><init>(Z)V HSPLokhttp3/internal/http/CallServerInterceptor;->intercept(Lokhttp3/Interceptor$Chain;)Lokhttp3/Response; HSPLokhttp3/internal/http/HttpHeaders;-><clinit>()V
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Mon Dec 30 23:28:56 GMT 2024 - 127.9K bytes - Click Count (1) -
okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt
// Capture the protocol as it is observed by the interceptor. val protocolRef = AtomicReference<Protocol?>() val interceptor = Interceptor { chain: Interceptor.Chain -> protocolRef.set(chain.connection()!!.protocol()) chain.proceed(chain.request()) } client = client .newBuilder() .addNetworkInterceptor(interceptor) .build()Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:02:18 GMT 2026 - 146.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
assertThat(Thread.interrupted()).isFalse(); SettableFuture<Integer> cancelledFuture = SettableFuture.create(); cancelledFuture.cancel(true); assertThat(Thread.interrupted()).isFalse(); ListenableFuture<Integer> future = submitAsync(() -> cancelledFuture, directExecutor()); assertThat(future.isDone()).isTrue(); assertThat(Thread.interrupted()).isFalse(); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 134K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
assertThat(Thread.interrupted()).isFalse(); SettableFuture<Integer> cancelledFuture = SettableFuture.create(); cancelledFuture.cancel(true); assertThat(Thread.interrupted()).isFalse(); ListenableFuture<Integer> future = submitAsync(() -> cancelledFuture, directExecutor()); assertThat(future.isDone()).isTrue(); assertThat(Thread.interrupted()).isFalse(); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 134K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt
`Exactly so,' said the Hatter: `as the things get used up.' `But what happens when you come to the beginning again?' Alice ventured to ask. `Suppose we change the subject,' the March Hare interrupted, yawning. `I'm getting tired of this. I vote the young lady tells us a story.' `I'm afraid I don't know one,' said Alice, rather alarmed at the proposal.
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Apr 21 02:27:51 GMT 2017 - 145.2K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt
* as a **network interceptor**. It will strip the `Location` header of impacted responses to * prevent the redirect. * * ``` * OkHttpClient client = client.newBuilder() * .addNetworkInterceptor(new LegacyRedirectInterceptor()) * .build(); * ``` */ internal class LegacyRedirectInterceptor : Interceptor {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 133.3K bytes - Click Count (0) -
guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt
`Exactly so,' said the Hatter: `as the things get used up.' `But what happens when you come to the beginning again?' Alice ventured to ask. `Suppose we change the subject,' the March Hare interrupted, yawning. `I'm getting tired of this. I vote the young lady tells us a story.' `I'm afraid I don't know one,' said Alice, rather alarmed at the proposal.
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Oct 29 21:35:03 GMT 2012 - 145.2K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbFile.java
return this.treeHandle; } catch (InterruptedException ie) { Thread.currentThread().interrupt(); throw new SmbException("Connection retry interrupted", ie); } catch (CIFSException retryException) { log.debug("Connection retry also failed", retryException); throw e; // Throw original exception }Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 103.2K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
* specified {@link MoreExecutors#directExecutor()}, those objects will be closed synchronously. * * @param mayInterruptIfRunning {@code true} if the thread executing this task should be * interrupted; otherwise, in-progress tasks are allowed to complete, but the step will be * cancelled regardless * @return {@code false} if the step could not be cancelled, typically because it has alreadyCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 101.7K bytes - Click Count (0)