Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 178 for Peeker (0.16 sec)

  1. 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)
  2. 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)
  3. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

                public U call(DeferredCloser closer, Peeker peeker) throws Exception {
                  return function.apply(
                      closer,
                      peeker.getDone(future1),
                      peeker.getDone(future2),
                      peeker.getDone(future3),
                      peeker.getDone(future4),
                      peeker.getDone(future5));
                }
    
                @Override
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue May 07 12:37:15 UTC 2024
    - 98.3K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/ClosingFuture.java

                public U call(DeferredCloser closer, Peeker peeker) throws Exception {
                  return function.apply(
                      closer,
                      peeker.getDone(future1),
                      peeker.getDone(future2),
                      peeker.getDone(future3),
                      peeker.getDone(future4),
                      peeker.getDone(future5));
                }
    
                @Override
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 98.7K bytes
    - Viewed (0)
  5. src/go/internal/gccgoimporter/ar.go

    		return ret
    	}
    	return seekerReadAt{rs}
    }
    
    type seekerReadAt struct {
    	seeker io.ReadSeeker
    }
    
    func (sra seekerReadAt) ReadAt(p []byte, off int64) (int, error) {
    	if _, err := sra.seeker.Seek(off, io.SeekStart); err != nil {
    		return 0, err
    	}
    	return sra.seeker.Read(p)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Sep 30 14:14:36 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top