- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 44 for Peeker (0.04 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)