Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 86 for Peeker (0.41 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. src/strings/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: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Dec 13 18:45:54 UTC 2021
    - 5.9K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/-ResponseCommon.kt

    ): String? = headers[name] ?: defaultValue
    
    @Throws(IOException::class)
    fun Response.commonPeekBody(byteCount: Long): ResponseBody {
      val peeked = body.source().peek()
      val buffer = Buffer()
      peeked.request(byteCount)
      buffer.write(peeked, minOf(byteCount, peeked.buffer.size))
      return buffer.asResponseBody(body.contentType(), buffer.size)
    }
    
    fun Response.commonNewBuilder(): Response.Builder = Response.Builder(this)
    
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Apr 15 13:24:48 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  7. test/typeparam/issue44688.go

    	var b1 B1[T]
    	b1.A1 = &A1[T]{}
    	b1.A2 = &ImpA2[T]{}
    
    	b1.A1.m1(arg)
    	b1.m1(arg)
    
    	b1.A2.m2(arg)
    	b1.m2(arg)
    
    	var b2 B2[T]
    	b2 = &ImpA2[T]{}
    	b2.m2(arg)
    
    	// a deeper nesting
    	var d D[T]
    	d.C.B1.A1 = &A1[T]{}
    	d.C.B1.A2 = &ImpA2[T]{}
    	d.m1(arg)
    	d.m2(arg)
    
    	// calling method expressions
    	m1x := B1[T].m1
    	m1x(b1, arg)
    	// TODO(khr): reenable these.
    	//m2x := B2[T].m2
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 01 19:45:34 UTC 2022
    - 1.9K bytes
    - Viewed (0)
  8. src/net/sendfile_unix_alt.go

    			return 0, nil, true
    		}
    	}
    	// r might be an *os.File or an os.fileWithoutWriteTo.
    	// Type assert to an interface rather than *os.File directly to handle the latter case.
    	f, ok := r.(interface {
    		fs.File
    		io.Seeker
    		syscall.Conn
    	})
    	if !ok {
    		return 0, nil, false
    	}
    
    	if remain == 0 {
    		fi, err := f.Stat()
    		if err != nil {
    			return 0, err, false
    		}
    
    		remain = fi.Size()
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 18:12:56 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  9. guava/src/com/google/common/io/FileWriteMode.java

    import com.google.common.annotations.J2ktIncompatible;
    
    /**
     * Modes for opening a file for writing. The default when mode when none is specified is to truncate
     * the file before writing.
     *
     * @author Colin Decker
     */
    @J2ktIncompatible
    @GwtIncompatible
    @ElementTypesAreNonnullByDefault
    public enum FileWriteMode {
      /** Specifies that writes to the opened file should append to the end of the file. */
      APPEND
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Feb 28 20:13:02 UTC 2023
    - 1.1K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/io/TestCharSource.java

    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.Reader;
    
    /**
     * A char source for testing that has configurable options.
     *
     * @author Colin Decker
     */
    public class TestCharSource extends CharSource implements TestStreamSupplier {
    
      private final TestByteSource byteSource;
    
      public TestCharSource(String content, TestOption... options) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Apr 21 02:27:51 UTC 2017
    - 1.4K bytes
    - Viewed (0)
Back to top