- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for Every (0.52 sec)
-
android/guava/src/com/google/common/collect/Iterators.java
while (iterator.hasNext()) { if (element.equals(iterator.next())) { return true; } } } return false; } /** * Traverses an iterator and removes every element that belongs to the provided collection. The * iterator will be left exhausted: its {@code hasNext()} method will return {@code false}. * * @param removeFrom the iterator to (potentially) remove elements from
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Apr 30 18:43:01 GMT 2024 - 51.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* exceptions). * </ul> * * <p>The overall principle is to continue to treat every checked exception as a checked * exception, every unchecked exception as an unchecked exception, and every error as an error. In * addition, the cause of any {@code ExecutionException} is wrapped in order to ensure that the * new stack trace matches that of the current thread.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 59.6K bytes - Viewed (0) -
guava/src/com/google/common/collect/Iterators.java
while (iterator.hasNext()) { if (element.equals(iterator.next())) { return true; } } } return false; } /** * Traverses an iterator and removes every element that belongs to the provided collection. The * iterator will be left exhausted: its {@code hasNext()} method will return {@code false}. * * @param removeFrom the iterator to (potentially) remove elements from
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Tue Jan 30 00:14:39 GMT 2024 - 50.5K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Multimaps.java
* underlying multimap. * * <p>The returned multimap isn't threadsafe or serializable, even if {@code unfiltered} is. * * <p>Many of the filtered multimap's methods, such as {@code size()}, iterate across every * key/value mapping in the underlying multimap and determine which satisfy the filter. When a * live view is <i>not</i> needed, it may be faster to copy the filtered multimap and use the * copy. *
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 86.4K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Sets.java
* * <p>The returned set isn't threadsafe or serializable, even if {@code unfiltered} is. * * <p>Many of the filtered set's methods, such as {@code size()}, iterate across every element in * the underlying set and determine which elements satisfy the filter. When a live view is * <i>not</i> needed, it may be faster to copy {@code Iterables.filter(unfiltered, predicate)} and * use the copy.
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 77.4K bytes - Viewed (0) -
cmd/batch-handlers.go
success = false } else { stopFn(oi, nil) } ri.trackCurrentBucketObject(r.Target.Bucket, oi, success) globalBatchJobsMetrics.save(job.ID, ri) // persist in-memory state to disk after every 10secs. batchLogIf(ctx, ri.updateAfter(ctx, api, 10*time.Second, job)) if wait := globalBatchConfig.ReplicationWait(); wait > 0 { time.Sleep(wait) } }() } wk.Wait()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 55.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
// this has 2 benefits // 1. for long chains of futures strung together with setFuture we consume less stack // 2. we avoid allocating Cancellation objects at every level of the cancellation // chain // We can only do this for TrustedFuture, because TrustedFuture.cancel is final and // does nothing but delegate to this method.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0) -
cmd/bucket-handlers.go
// ---------- // Places an Object Lock configuration on the specified bucket. The rule // specified in the Object Lock configuration will be applied by default // to every new object placed in the specified bucket. func (api objectAPIHandlers) PutBucketObjectLockConfigHandler(w http.ResponseWriter, r *http.Request) { ctx := newContext(r, w, "PutBucketObjectLockConfig")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 16:27:27 GMT 2024 - 61.6K bytes - Viewed (0) -
cmd/test-utils_test.go
) // Temp files created in default Tmp dir var globalTestTmpDir = os.TempDir() // reseed - returns a new seed every time the function is called. func reseed() uint32 { return uint32(time.Now().UnixNano() + int64(os.Getpid())) } // nextSuffix - provides a new unique suffix every time the function is called. func nextSuffix() string { randmu.Lock() r := randN // Initial seed required, generate one.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
@ParameterizedTest @ArgumentsSource(ProtocolParamProvider::class) fun pingsTransmitted( protocol: Protocol, mockWebServer: MockWebServer, ) { setUp(protocol, mockWebServer) // Ping every 500 ms, starting at 500 ms. client = client.newBuilder() .pingInterval(Duration.ofMillis(500)) .build() // Delay the response to give 1 ping enough time to be sent and replied to.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0)