- Sort Score
- Num 10 results
- Language All
Results 81 - 90 of 122 for callArgs (0.08 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
okhttp/src/jvmTest/kotlin/okhttp3/InterceptorTest.kt
@Test fun networkInterceptorThrowsRuntimeExceptionSynchronous() { interceptorThrowsRuntimeExceptionSynchronous(true) } /** * When an interceptor throws an unexpected exception, synchronous callers can catch it and deal * with it. */ private fun interceptorThrowsRuntimeExceptionSynchronous(network: Boolean) { addInterceptor(network) { chain: Interceptor.Chain? -> throw RuntimeException("boom!") }
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 16:11:23 GMT 2025 - 28.2K bytes - Click Count (0) -
guava/src/com/google/common/collect/LinkedListMultimap.java
node.previousSibling = keyTail; keyList.tail = node; } } else { // non-empty list, insert before nextSibling /* * requireNonNull is safe as long as callers pass a nextSibling that (a) has the same key and * (b) is present in the multimap. (And they do, except maybe in case of concurrent * modification, in which case all bets are off.) */Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 18:35:44 GMT 2025 - 27K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
/** * It is implicitly assumed that all the services are NEW and that they will all remain NEW * until all the Listeners are installed and {@link #markReady()} is called. It is our caller's * responsibility to only call {@link #markReady()} if all services were new at the time this * method was called and when all the listeners were installed. */Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 17:49:12 GMT 2025 - 33.2K bytes - Click Count (1) -
guava/src/com/google/common/util/concurrent/ServiceManager.java
/** * It is implicitly assumed that all the services are NEW and that they will all remain NEW * until all the Listeners are installed and {@link #markReady()} is called. It is our caller's * responsibility to only call {@link #markReady()} if all services were new at the time this * method was called and when all the listeners were installed. */Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 17:49:12 GMT 2025 - 32.9K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cookie.kt
* value. */ @get:JvmName("sameSite") val sameSite: String?, ) { /** * Returns true if this cookie should be included on a request to [url]. In addition to this * check callers should also confirm that this cookie has not expired. */ fun matches(url: HttpUrl): Boolean { val domainMatch = if (hostOnly) { url.host == domain } else {Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Mon May 05 16:01:00 GMT 2025 - 23.1K bytes - Click Count (0) -
internal/dsync/drwmutex.go
} } }() return quorumLocked } // checkFailedUnlocks determines whether we have sufficiently unlocked all // resources to ensure no deadlocks for future callers func checkFailedUnlocks(locks []string, tolerance int) bool { unlocksFailed := 0 for lockID := range locks { if isLocked(locks[lockID]) { unlocksFailed++ } }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 20.3K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt
* * This class is tolerant of some I/O errors. If files are missing from the filesystem, the * corresponding entries will be dropped from the cache. If an error occurs while writing a cache * value, the edit will fail silently. Callers should handle other problems by catching * `IOException` and responding appropriately. * * @constructor Create a cache which will reside in [directory]. This cache is lazily initialized on
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed May 28 23:28:25 GMT 2025 - 34.7K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt
internal fun writeHeaders( streamId: Int, outFinished: Boolean, alternating: List<Header>, ) { writer.headers(outFinished, streamId, alternating) } /** * Callers of this method are not thread safe, and sometimes on application threads. Most often, * this method will be called to send a buffer worth of data to the peer. *
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 31.8K bytes - Click Count (0) -
guava/src/com/google/common/math/Stats.java
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Jul 08 18:32:10 GMT 2025 - 24.8K bytes - Click Count (0) -
android/guava/src/com/google/common/primitives/Ints.java
public Integer get(int index) { checkElementIndex(index, size()); return array[start + index]; } @Override /* * This is an override that is not directly visible to callers, so NewApi will catch calls to * Collection.spliterator() where necessary. */ @IgnoreJRERequirement public Spliterator.OfInt spliterator() { return Spliterators.spliterator(array, start, end, 0);
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Oct 22 18:14:49 GMT 2025 - 31.3K bytes - Click Count (0)