- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 543 for NewMreader (0.15 sec)
-
src/cmd/internal/cov/mreader.go
// on explicit reads + seeks provided by bio.Reader if needed. type MReader struct { f *os.File rdr *bio.Reader fileView []byte off int64 } func NewMreader(f *os.File) (*MReader, error) { rdr := bio.NewReader(f) fi, err := f.Stat() if err != nil { return nil, err } r := MReader{ f: f, rdr: rdr, fileView: rdr.SliceRO(uint64(fi.Size())), } return &r, nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 10 18:12:25 UTC 2023 - 1.8K bytes - Viewed (0) -
src/cmd/internal/cov/readcovdata.go
cf, err := os.Open(cdf) if err != nil { return r.fatal("opening counter data file %s: %s", cdf, err) } defer func(f *os.File) { f.Close() }(cf) var mr *MReader mr, err = NewMreader(cf) if err != nil { return r.fatal("creating reader for counter data file %s: %s", cdf, err) } var cdr *decodecounter.CounterDataReader cdr, err = decodecounter.NewCounterDataReader(cdf, mr)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 8.4K bytes - Viewed (0) -
internal/hash/reader_test.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 18 17:00:54 UTC 2023 - 10.3K bytes - Viewed (0) -
src/io/example_test.go
} func ExampleLimitReader() { r := strings.NewReader("some io.Reader stream to be read\n") lr := io.LimitReader(r, 4) if _, err := io.Copy(os.Stdout, lr); err != nil { log.Fatal(err) } // Output: // some } func ExampleMultiReader() { r1 := strings.NewReader("first reader ") r2 := strings.NewReader("second reader ") r3 := strings.NewReader("third reader\n") r := io.MultiReader(r1, r2, r3)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 06 15:49:32 UTC 2022 - 5.5K bytes - Viewed (0) -
src/internal/saferio/io_test.go
_, err := ReadData(bytes.NewReader(input), 1<<62) if err == nil { t.Error("large read succeeded unexpectedly") } }) t.Run("small-EOF", func(t *testing.T) { _, err := ReadData(bytes.NewReader(nil), chunk-1) if err != io.EOF { t.Errorf("ReadData = %v, want io.EOF", err) } }) t.Run("large-EOF", func(t *testing.T) { _, err := ReadData(bytes.NewReader(nil), chunk+1) if err != io.EOF {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Aug 31 00:34:05 UTC 2023 - 3.1K bytes - Viewed (0) -
src/compress/flate/inflate_test.go
{"\x02", ""}, {"\xf2H\xcd", "He"}, {"\xf2H͙0a\u0084\t", "Hel\x90\x90\x90\x90\x90"}, {"\xf2H͙0a\u0084\t\x00", "Hel\x90\x90\x90\x90\x90"}, } for i, v := range vectors { r := strings.NewReader(v.input) zr := NewReader(r) b, err := io.ReadAll(zr) if err != io.ErrUnexpectedEOF { t.Errorf("test %d, error mismatch: got %v, want io.ErrUnexpectedEOF", i, err) } if string(b) != v.output {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 24 23:23:54 UTC 2023 - 3.3K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/yaml/decoder_test.go
r := NewDocumentDecoder(io.NopCloser(bytes.NewReader([]byte(dd[:maxLen-1])))) b := make([]byte, bufferLen) n, err := r.Read(b) if err != io.ErrShortBuffer { t.Fatalf("expected ErrShortBuffer: %d / %v", n, err) } b = make([]byte, maxLen) n, err = r.Read(b) if err != nil { t.Fatalf("expected nil: %d / %v", n, err) } r = NewDocumentDecoder(io.NopCloser(bytes.NewReader([]byte(dd)))) b = make([]byte, maxLen)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 10 07:29:34 UTC 2023 - 12.4K bytes - Viewed (0) -
cmd/untar.go
bf := bufio.NewReader(r) switch f := detect(bf); f { case formatGzip: gz, err := gzip.NewReader(bf) if err != nil { return err } defer gz.Close() r = gz case formatS2: r = s2.NewReader(bf) case formatZstd: // Limit to 16 MiB per stream. dec, err := zstd.NewReader(bf, zstd.WithDecoderMaxWindow(16<<20)) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 6K bytes - Viewed (0) -
src/bufio/bufio_test.go
} } return string(b[0:nb]) } func TestReaderSimple(t *testing.T) { data := "hello world" b := NewReader(strings.NewReader(data)) if s := readBytes(b); s != "hello world" { t.Errorf("simple hello world test failed: got %q", s) } b = NewReader(newRot13Reader(strings.NewReader(data))) if s := readBytes(b); s != "uryyb jbeyq" { t.Errorf("rot13 hello world test failed: got %q", s) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 10 18:56:01 UTC 2023 - 51.5K bytes - Viewed (0) -
src/mime/multipart/formdata_test.go
package multipart import ( "bytes" "fmt" "io" "math" "net/textproto" "os" "strings" "testing" ) func TestReadForm(t *testing.T) { b := strings.NewReader(strings.ReplaceAll(message, "\n", "\r\n")) r := NewReader(b, boundary) f, err := r.ReadForm(25) if err != nil { t.Fatal("ReadForm:", err) } defer f.RemoveAll() if g, e := f.Value["texta"][0], textaValue; g != e {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 05 18:31:56 UTC 2024 - 14K bytes - Viewed (0)