Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 44 for Peeker (0.04 sec)

  1. cmd/metrics-v2_test.go

    		// synchronization used internally.
    		<-ticker.C
    		ttfbHist.With(prometheus.Labels{"api": obs.label}).Observe(obs.val)
    	}
    
    	// Accumulate regular-cased API label metrics for 'PutObject' for deeper verification
    	metrics := getHistogramMetrics(ttfbHist, getBucketTTFBDistributionMD(), false, false)
    	capitalPutObjects := make([]MetricV2, 0, len(histBuckets)+1)
    	for _, metric := range metrics {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 6.8K bytes
    - Viewed (0)
  2. src/bytes/reader_test.go

    	}
    
    	for i, tt := range tests {
    		pos, err := r.Seek(tt.off, tt.seek)
    		if err == nil && tt.seekerr != "" {
    			t.Errorf("%d. want seek error %q", i, tt.seekerr)
    			continue
    		}
    		if err != nil && err.Error() != tt.seekerr {
    			t.Errorf("%d. seek error = %q; want %q", i, err.Error(), tt.seekerr)
    			continue
    		}
    		if tt.wantpos != 0 && tt.wantpos != pos {
    			t.Errorf("%d. pos = %d, want %d", i, pos, tt.wantpos)
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon Dec 13 18:45:54 UTC 2021
    - 8K bytes
    - Viewed (0)
  3. src/bytes/reader.go

    // license that can be found in the LICENSE file.
    
    package bytes
    
    import (
    	"errors"
    	"io"
    	"unicode/utf8"
    )
    
    // A Reader implements the [io.Reader], [io.ReaderAt], [io.WriterTo], [io.Seeker],
    // [io.ByteScanner], and [io.RuneScanner] interfaces by reading from
    // a byte slice.
    // Unlike a [Buffer], a Reader is read-only and supports seeking.
    // The zero value for Reader operates like a Reader of an empty slice.
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Jul 16 18:17:37 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/io/TestCharSource.java

    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.Reader;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * A char source for testing that has configurable options.
     *
     * @author Colin Decker
     */
    @NullUnmarked
    public class TestCharSource extends CharSource implements TestStreamSupplier {
    
      private final TestByteSource byteSource;
    
      public TestCharSource(String content, TestOption... options) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java

    import java.util.concurrent.TimeUnit;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Tests for {@link AbstractListeningExecutorService}.
     *
     * @author Colin Decker
     */
    @NullUnmarked
    public class AbstractListeningExecutorServiceTest extends TestCase {
    
      public void testSubmit() throws Exception {
        /*
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java

    import java.util.concurrent.TimeUnit;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Tests for {@link AbstractListeningExecutorService}.
     *
     * @author Colin Decker
     */
    @NullUnmarked
    public class AbstractListeningExecutorServiceTest extends TestCase {
    
      public void testSubmit() throws Exception {
        /*
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/io/TestOption.java

     */
    
    package com.google.common.io;
    
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Options controlling the behavior of sources/sinks/streams for testing.
     *
     * @author Colin Decker
     */
    @NullUnmarked
    public enum TestOption {
      OPEN_THROWS,
      SKIP_THROWS,
      READ_THROWS,
      WRITE_THROWS,
      CLOSE_THROWS,
      AVAILABLE_ALWAYS_ZERO
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 931 bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/io/TestOption.java

     */
    
    package com.google.common.io;
    
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Options controlling the behavior of sources/sinks/streams for testing.
     *
     * @author Colin Decker
     */
    @NullUnmarked
    public enum TestOption {
      OPEN_THROWS,
      SKIP_THROWS,
      READ_THROWS,
      WRITE_THROWS,
      CLOSE_THROWS,
      AVAILABLE_ALWAYS_ZERO
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 931 bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/HttpHeaders.kt

        while (true) {
          if (peek == null) {
            peek = readToken()
            if (skipCommasAndWhitespace()) break // We peeked a scheme name followed by ','.
            eqCount = skipAll('='.code.toByte())
          }
          if (eqCount == 0) break // We peeked a scheme name.
          if (eqCount > 1) return // Unexpected '=' characters.
          if (skipCommasAndWhitespace()) return // Unexpected ','.
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/io/TestReader.java

    import java.io.ByteArrayInputStream;
    import java.io.FilterReader;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * @author Colin Decker
     */
    @NullUnmarked
    public class TestReader extends FilterReader {
    
      private final TestInputStream in;
    
      public TestReader(TestOption... options) throws IOException {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 1.4K bytes
    - Viewed (0)
Back to top