Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1651 - 1660 of 1,832 for collector (0.04 sec)

  1. android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java

     * or implied. See the License for the specific language governing permissions and limitations under
     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.collect.Sets.newConcurrentHashSet;
    import static java.util.Objects.requireNonNull;
    import static java.util.concurrent.atomic.AtomicIntegerFieldUpdater.newUpdater;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  2. cmd/object-api-multipart_test.go

    	if err != nil {
    		// Failed to create newbucket, abort.
    		t.Fatalf("%s : %s", instanceType, err.Error())
    	}
    
    	obj.DeleteBucket(context.Background(), "abc", DeleteBucketOptions{})
    
    	// Collection of non-exhaustive PutObjectPart test cases, valid errors
    	// and success responses.
    	testCases := []struct {
    		bucketName      string
    		objName         string
    		uploadID        string
    		PartID          int
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.4K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

    import static java.util.concurrent.TimeUnit.NANOSECONDS;
    import static java.util.concurrent.TimeUnit.SECONDS;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.collect.ImmutableClassToInstanceMap;
    import com.google.common.collect.ImmutableSet;
    import com.google.common.testing.NullPointerTester;
    import com.google.common.testing.NullPointerTester.Visibility;
    import com.google.common.util.concurrent.RateLimiter.SleepingStopwatch;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 21.9K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

    import static java.util.concurrent.TimeUnit.NANOSECONDS;
    import static java.util.concurrent.TimeUnit.SECONDS;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.collect.ImmutableClassToInstanceMap;
    import com.google.common.collect.ImmutableSet;
    import com.google.common.testing.NullPointerTester;
    import com.google.common.testing.NullPointerTester.Visibility;
    import com.google.common.util.concurrent.RateLimiter.SleepingStopwatch;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 21.9K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java

    package com.google.common.base;
    
    import static com.google.common.truth.Truth.assertThat;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.base.internal.Finalizer;
    import com.google.common.collect.Sets;
    import com.google.common.testing.GcFinalization;
    import java.io.Closeable;
    import java.io.IOException;
    import java.io.UncheckedIOException;
    import java.lang.ref.Cleaner;
    import java.lang.ref.Cleaner.Cleanable;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 8.7K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java

    package com.google.common.base;
    
    import static com.google.common.truth.Truth.assertThat;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.base.internal.Finalizer;
    import com.google.common.collect.Sets;
    import com.google.common.testing.GcFinalization;
    import java.io.Closeable;
    import java.io.IOException;
    import java.io.UncheckedIOException;
    import java.lang.ref.Cleaner;
    import java.lang.ref.Cleaner.Cleanable;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 8.7K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/core/collection/SLinkedListTest.java

     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
     * either express or implied. See the License for the specific language
     * governing permissions and limitations under the License.
     */
    package org.codelibs.core.collection;
    
    import static org.hamcrest.CoreMatchers.is;
    import static org.hamcrest.CoreMatchers.not;
    import static org.hamcrest.CoreMatchers.notNullValue;
    import static org.hamcrest.CoreMatchers.nullValue;
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Sat May 10 01:32:17 UTC 2025
    - 8.3K bytes
    - Viewed (0)
  8. cmd/erasure-metadata-utils_test.go

    		cdiskCount := diskCount(testCase.disks)
    		if cdiskCount != testCase.diskCount {
    			t.Errorf("Test %d: Expected %d, got %d", i+1, testCase.diskCount, cdiskCount)
    		}
    	}
    }
    
    // Test for reduceErrs, reduceErr reduces collection
    // of errors into a single maximal error with in the list.
    func TestReduceErrs(t *testing.T) {
    	canceledErrs := make([]error, 0, 5)
    	for i := range 5 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  9. android/guava-tests/benchmark/com/google/common/base/AsciiBenchmark.java

     * limitations under the License.
     */
    
    package com.google.common.base;
    
    import com.google.caliper.BeforeExperiment;
    import com.google.caliper.Benchmark;
    import com.google.caliper.Param;
    import com.google.common.collect.Lists;
    import com.google.common.primitives.Chars;
    import java.util.Collections;
    import java.util.List;
    import java.util.Locale;
    import java.util.Random;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  10. android/guava-tests/benchmark/com/google/common/collect/BinaryTreeTraverserBenchmark.java

     * or implied. See the License for the specific language governing permissions and limitations under
     * the License.
     */
    
    package com.google.common.collect;
    
    import com.google.caliper.BeforeExperiment;
    import com.google.caliper.Benchmark;
    import com.google.caliper.Param;
    import com.google.common.base.Optional;
    import com.google.common.primitives.Ints;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 4.9K bytes
    - Viewed (0)
Back to top