- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 178 for Peeker (0.16 sec)
-
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
throws Exception { closer.eventuallyClose(closeable1, closingExecutor); assertThat(peeker.getDone(input1)).isSameInstanceAs("value1"); try { peeker.getDone(input2Failed); fail("Peeker should fail for failed inputs");
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 75.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
throws Exception { closer.eventuallyClose(closeable1, closingExecutor); assertThat(peeker.getDone(input1)).isSameInstanceAs("value1"); try { peeker.getDone(input2Failed); fail("Peeker should fail for failed inputs");
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 75.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 98.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ClosingFuture.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 98.7K bytes - Viewed (0) -
src/go/internal/gccgoimporter/ar.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 30 14:14:36 UTC 2022 - 4.4K bytes - Viewed (0) -
src/embed/internal/embedtest/embed_test.go
n, err = file.Read(buf[:]) if err != io.EOF { t.Fatal("Read:", err) } if n != 0 { t.Fatal("Read:", n) } // Use seek to get the offset at the EOF. seeker := file.(io.Seeker) off, err := seeker.Seek(0, io.SeekCurrent) if err != nil { t.Fatal("Seek:", err) } if off != int64(len(want)) { t.Fatal("Seek:", off) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 14 20:10:16 UTC 2023 - 5.4K bytes - Viewed (0) -
src/internal/zstd/zstd.go
return nil } if seeker, ok := r.r.(io.Seeker); ok { r.blockOffset += int64(relativeOffset) // Implementations of Seeker do not always detect invalid offsets, // so check that the new offset is valid by comparing to the end. prev, err := seeker.Seek(0, io.SeekCurrent) if err != nil { return r.wrapError(0, err) } end, err := seeker.Seek(0, io.SeekEnd) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jan 30 04:10:45 UTC 2024 - 12.7K bytes - Viewed (0) -
src/strings/reader.go
package strings import ( "errors" "io" "unicode/utf8" ) // A Reader implements the [io.Reader], [io.ReaderAt], [io.ByteReader], [io.ByteScanner], // [io.RuneReader], [io.RuneScanner], [io.Seeker], and [io.WriterTo] interfaces by reading // from a string. // The zero value for Reader operates like a Reader of an empty string. type Reader struct { s string i int64 // current reading index
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 13 17:10:31 UTC 2023 - 3.9K bytes - Viewed (0) -
src/net/http/fs.go
// served by the [FileServer] implementation. // // The methods should behave the same as those on an [*os.File]. type File interface { io.Closer io.Reader io.Seeker Readdir(count int) ([]fs.FileInfo, error) Stat() (fs.FileInfo, error) } type anyDirs interface { len() int name(i int) string isDir(i int) bool } type fileInfoDirs []fs.FileInfo
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 09 17:06:47 UTC 2024 - 31.1K bytes - Viewed (0) -
src/testing/run_example_wasm.go
// Restore stdout, get output and remove temporary file. os.Stdout = stdout var buf strings.Builder _, seekErr := f.Seek(0, io.SeekStart) _, readErr := io.Copy(&buf, f) out := buf.String() f.Close() os.Remove(f.Name()) if seekErr != nil { fmt.Fprintf(os.Stderr, "testing: seek temp file: %v\n", seekErr) os.Exit(1) } if readErr != nil { fmt.Fprintf(os.Stderr, "testing: read temp file: %v\n", readErr)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 11 20:56:32 UTC 2023 - 1.8K bytes - Viewed (0)