- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for resultCh (0.05 sec)
-
cmd/batch-handlers.go
resultCh := make(chan itemOrErr[ObjectInfo]) ctx, cancel := context.WithCancel(ctx) defer cancel() if err := objectAPI.Walk(ctx, minioMetaBucket, batchJobReportsPrefix, resultCh, WalkOptions{}); err != nil { return err } for result := range resultCh { if result.Err != nil { return result.Err } ri := &batchJobInfo{}
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 63.5K bytes - Viewed (0) -
tests/query_test.go
} for idx := range results { results[idx].Name = results[idx].Name + "_new" } if err := tx.Save(results).Error; err != nil { t.Fatalf("failed to save users, got error %v", err) } return nil }); result.Error != nil || result.RowsAffected != 6 { t.Errorf("Failed to batch find, got error %v, rows affected: %v", result.Error, result.RowsAffected) } if totalBatch != 6 {
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Tue Jul 22 06:21:04 UTC 2025 - 51K bytes - Viewed (0) -
src/bytes/bytes_test.go
b := []byte(tt.s) a := Fields(b) // Appending to the results should not change future results. var x []byte for _, v := range a { x = append(v, 'z') } result := sliceOfString(a) if !slices.Equal(result, tt.a) { t.Errorf("Fields(%q) = %v; want %v", tt.s, a, tt.a) continue } result2 := sliceOfString(collect(t, FieldsSeq([]byte(tt.s))))
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Mon Jul 28 18:13:58 UTC 2025 - 62.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* a POJO. * * @param input The future to transform * @param function A Function to transform the results of the provided future to the results of * the returned future. * @param executor Executor to run the function in. * @return A future that holds result of the transformation. * @since 9.0 (in 2.0 as {@code compose}) */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 64.3K bytes - Viewed (0) -
tensorflow/c/c_api.h
// `src_names` are owned by and have the lifetime of `results`. TF_CAPI_EXPORT extern void TF_ImportGraphDefResultsMissingUnusedInputMappings( TF_ImportGraphDefResults* results, int* num_missing_unused_input_mappings, const char*** src_names, int** src_indexes); // Deletes a results object returned by TF_GraphImportGraphDefWithResults().
Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Thu Oct 26 21:08:15 UTC 2023 - 82.3K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Multimaps.java
if (result == null) { entries = result = unmodifiableEntries(delegate.entries()); } return result; } @Override public Collection<V> get(@ParametricNullness K key) { return unmodifiableValueCollection(delegate.get(key)); } @Override public Multiset<K> keys() { Multiset<K> result = keys; if (result == null) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 86.6K bytes - Viewed (0) -
guava/src/com/google/common/collect/Multimaps.java
@Override public Multiset<K> keys() { Multiset<K> result = keys; if (result == null) { keys = result = Multisets.unmodifiableMultiset(delegate.keys()); } return result; } @Override public Set<K> keySet() { Set<K> result = keySet; if (result == null) { keySet = result = Collections.unmodifiableSet(delegate.keySet()); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 86.9K bytes - Viewed (0) -
cmd/object-api-multipart_test.go
// Test case with keyMarker less than 0. (Test number 20). // {bucketNames[0], "", "min", "", "", -1, listMultipartResults[7], nil, true}, // The result contains only one entry. The KeyPrefix is set to the object name in the result. // Expecting the result to skip the KeyPrefix entry in the result (Test number 21). {bucketNames[0], "", "minio-object", "", "", 2, listMultipartResults[8], nil, true}, // Test case containing prefix values.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 89.4K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Sets.java
@Override public NavigableSet<E> descendingSet() { UnmodifiableNavigableSet<E> result = descendingSet; if (result == null) { result = descendingSet = new UnmodifiableNavigableSet<>(delegate.descendingSet()); result.descendingSet = this; } return result; } @Override public Iterator<E> descendingIterator() {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 81.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/HttpUrl.kt
*/ fun newBuilder(): Builder { val result = Builder() result.scheme = scheme result.encodedUsername = encodedUsername result.encodedPassword = encodedPassword result.host = host // If we're set to a default port, unset it in case of a scheme change. result.port = if (port != defaultPort(scheme)) port else -1 result.encodedPathSegments.clear() result.encodedPathSegments.addAll(encodedPathSegments)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon May 05 16:01:00 UTC 2025 - 63.5K bytes - Viewed (0)