- Sort Score
- Num 10 results
- Language All
Results 251 - 260 of 795 for Calls (0.02 seconds)
-
android/guava/src/com/google/common/collect/Ordering.java
public String toString() { return "Ordering.arbitrary()"; } /* * We need to be able to mock identityHashCode() calls for tests, because it * can take 1-10 seconds to find colliding objects. Mocking frameworks that * can do magic to mock static method calls still can't do so for a system * class, so we need the indirection. In production, Hotspot should still
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 39.4K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt
val connection = this.connection!! connection.assertLockHeld() val calls = connection.calls val index = calls.indexOfFirst { it.get() == this@RealCall } check(index != -1) calls.removeAt(index) this.connection = null if (calls.isEmpty()) { connection.idleAtNs = System.nanoTime() if (connectionPool.connectionBecameIdle(connection)) {Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Jan 11 12:06:21 GMT 2026 - 19.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/cache/CacheEvictionTest.java
assertThat(cache.asMap().keySet()).containsExactly(2, 4); CacheTesting.processPendingNotifications(cache); assertThat(removalListener.getCount()).isEqualTo(2); // Should we pepper more of these calls throughout the above? Where? CacheTesting.checkValidState(cache); } /** * Tests that when a single entry exceeds the segment's max weight, the new entry is immediately * evicted and nothing else.
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 18 18:06:14 GMT 2026 - 15K bytes - Click Count (0) -
android/guava/src/com/google/common/cache/ForwardingLoadingCache.java
import com.google.common.collect.ImmutableMap; import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.util.concurrent.ExecutionException; /** * A cache which forwards all its method calls to another cache. Subclasses should override one or * more methods to modify the behavior of the backing cache as desired per the <a * href="http://en.wikipedia.org/wiki/Decorator_pattern">decorator pattern</a>. *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 03 12:40:22 GMT 2026 - 3K bytes - Click Count (0) -
guava/src/com/google/common/collect/ForwardingMap.java
import java.util.Collection; import java.util.Iterator; import java.util.Map; import java.util.Objects; import java.util.Set; import org.jspecify.annotations.Nullable; /** * A map which forwards all its method calls to another map. Subclasses should override one or more * methods to modify the behavior of the backing map as desired per the <a * href="http://en.wikipedia.org/wiki/Decorator_pattern">decorator pattern</a>. *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Aug 06 17:32:30 GMT 2025 - 9.8K bytes - Click Count (0) -
docs/en/docs/advanced/testing-dependencies.md
You probably want to test the external provider once, but not necessarily call it for every test that runs. In this case, you can override the dependency that calls that provider, and use a custom dependency that returns a mock user, only for your tests. ### Use the `app.dependency_overrides` attribute { #use-the-app-dependency-overrides-attribute }Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Sun Aug 31 09:15:41 GMT 2025 - 2.4K bytes - Click Count (0) -
cmd/admin-handlers_test.go
if err != nil { t.Fatal("Failed to initialize a single node Erasure backend for admin handler tests.", err) } defer adminTestBed.TearDown() // Initialize admin peers to make admin RPC calls. Note: In a // single node setup, this degenerates to a simple function // call under the hood. globalMinioAddr = "127.0.0.1:9000" var wg sync.WaitGroupCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 13.9K bytes - Click Count (1) -
cmd/globals.go
globalTCPOptions xhttp.TCPOptions globalHTTPServerErrorCh = make(chan error) globalOSSignalCh = make(chan os.Signal, 1) // global Trace system to send HTTP request/response // and Storage/OS calls info to registered listeners. globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8) // global Listen system to send S3 API events to registered listeners globalHTTPListen = pubsub.New[event.Event, pubsub.Mask](0)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Sep 03 18:23:41 GMT 2024 - 16.2K bytes - Click Count (1) -
guava/src/com/google/common/base/Stopwatch.java
* are inherently approximate, routinely affected by periodic clock corrections. Because this class * (by default) uses {@link System#nanoTime}, it is unaffected by these changes. * * <p>Use this class instead of direct calls to {@link System#nanoTime} for two reasons: * * <ul> * <li>The raw {@code long} values returned by {@code nanoTime} are meaningless and unsafe to use * in any other way than how {@code Stopwatch} uses them.Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Oct 08 18:55:33 GMT 2025 - 9.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/UncheckedThrowingFuture.java
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import org.jspecify.annotations.NullUnmarked; /** * A {@link Future} implementation which always throws directly from calls to {@code get()} (i.e. * not wrapped in {@code ExecutionException}. For just a normal failure, use {@link * SettableFuture}). * * <p>Useful for testing the behavior of Future utilities against odd futures. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Dec 19 18:03:30 GMT 2024 - 3.3K bytes - Click Count (0)