Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for resultCh (0.05 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top