- Sort Score
- Result 10 results
- Languages All
Results 421 - 430 of 799 for Returned (0.05 sec)
-
guava/src/com/google/common/collect/HashMultimap.java
* <p>The multimap does not store duplicate key-value pairs. Adding a new key-value pair equal to an * existing key-value pair has no effect. * * <p>Keys and values may be null. All optional multimap methods are supported, and all returned * views are modifiable. * * <p>This class is not threadsafe when any concurrent operations update the multimap. Concurrent * read operations will work correctly if the last write <i>happens-before</i> any reads. To allow
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Aug 02 10:02:49 UTC 2024 - 6.1K bytes - Viewed (0) -
internal/pubsub/pubsub.go
return } } } }() return nil } // NumSubscribers returns the number of current subscribers, // The mask is checked against the active subscribed types, // and 0 will be returned if nobody is subscribed for the type(s). func (ps *PubSub[T, M]) NumSubscribers(mask M) int32 { types := Mask(atomic.LoadUint64(&ps.types)) if !types.Overlaps(Mask(mask.Mask())) { return 0 }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Feb 06 16:57:30 UTC 2024 - 5.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/ReflectionFreeAssertThrows.java
} if (userPassedSupplier) { throw new AssertionError( "expected to throw " + expectedThrowable.getSimpleName() + " but returned result: " + result); } else { throw new AssertionError("expected to throw " + expectedThrowable.getSimpleName()); } } private enum PlatformSpecificExceptionBatch {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 16:27:30 UTC 2024 - 6.3K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/ReflectionFreeAssertThrows.java
} if (userPassedSupplier) { throw new AssertionError( "expected to throw " + expectedThrowable.getSimpleName() + " but returned result: " + result); } else { throw new AssertionError("expected to throw " + expectedThrowable.getSimpleName()); } } private enum PlatformSpecificExceptionBatch {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 20:00:30 UTC 2024 - 6.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractIdleService.java
* this method to use a custom {@link Executor}, which may configure its worker thread with a * specific name, thread group or priority. The returned executor's {@link * Executor#execute(Runnable) execute()} method is called when this service is started and * stopped, and should return promptly. */ protected Executor executor() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Apr 17 13:59:28 UTC 2023 - 5.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/ReflectionFreeAssertThrows.java
} if (userPassedSupplier) { throw new AssertionError( "expected to throw " + expectedThrowable.getSimpleName() + " but returned result: " + result); } else { throw new AssertionError("expected to throw " + expectedThrowable.getSimpleName()); } } private enum PlatformSpecificExceptionBatch {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 16:27:30 UTC 2024 - 6.3K bytes - Viewed (0) -
cmd/background-heal-ops.go
// failure error occurred. func healDiskFormat(ctx context.Context, objAPI ObjectLayer, opts madmin.HealOpts) (madmin.HealResultItem, error) { res, err := objAPI.HealFormat(ctx, opts.DryRun) // return any error, ignore error returned when disks have // already healed. if err != nil && err != errNoHealRequired { return madmin.HealResultItem{}, err } return res, nil
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache_test.go
} ns2 := newFakeNsInode(inc(), 1) wl2 := WorkloadInfo{ Workload: podToWorkload(pod), Netns: ns2, } // when using same uid, the original netns should be returned netns2 := p.UpsertPodCacheWithNetns(string(pod.UID), wl2) if netns2 != ns { t.Fatalf("Expected the original Netns for the same uid, got %p and %p", netns2, ns) } if !ns2.closed.Load() {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Aug 14 19:36:19 UTC 2024 - 4.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractService.java
/** * This method is called by {@link #startAsync} to initiate service startup. The invocation of * this method should cause a call to {@link #notifyStarted()}, either during this method's run, * or after it has returned. If startup fails, the invocation should cause a call to {@link * #notifyFailed(Throwable)} instead. * * <p>This method should return promptly; prefer to do work on a different thread where it is
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 20.7K bytes - Viewed (0) -
internal/etag/etag.go
// // For a more detailed description of S3 ETags // take a look at the package documentation. type ETag []byte // String returns the string representation of the ETag. // // The returned string is a hex representation of the // binary ETag with an optional '-<part-number>' suffix. func (e ETag) String() string { if e.IsMultipart() { return hex.EncodeToString(e[:16]) + string(e[16:]) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Mar 10 21:09:36 UTC 2024 - 13.3K bytes - Viewed (0)