- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for ErrReader (0.32 sec)
-
src/testing/iotest/reader.go
r.count++ if r.count == 2 { return 0, ErrTimeout } return r.r.Read(p) } // ErrReader returns an [io.Reader] that returns 0, err from all Read calls. func ErrReader(err error) io.Reader { return &errReader{err: err} } type errReader struct { err error } func (r *errReader) Read(p []byte) (int, error) { return 0, r.err } type smallByteReader struct { r io.Reader
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 08 17:55:47 UTC 2023 - 8K bytes - Viewed (0) -
src/net/http/requestwrite_test.go
ProtoMinor: 1, ContentLength: 0, // as if unset by user }, Body: func() io.ReadCloser { err := errors.New("Custom reader error") errReader := iotest.ErrReader(err) return io.NopCloser(io.MultiReader(strings.NewReader("x"), errReader)) }, WantError: errors.New("Custom reader error"), }, // Request with a 0 ContentLength and a body without content and an error. 13: {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 07 01:07:32 UTC 2022 - 23.3K bytes - Viewed (0) -
src/testing/iotest/logger_test.go
log.SetOutput(olw) }() lOut := new(strings.Builder) log.SetPrefix("lr: ") log.SetOutput(lOut) log.SetFlags(0) data := []byte("Hello, World!") p := make([]byte, len(data)) lr := ErrReader(errors.New("io failure")) rl := NewReadLogger("read", lr) n, err := rl.Read(p) if err == nil { t.Fatalf("Unexpectedly succeeded to read: %v", err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 07 07:03:10 UTC 2022 - 3.4K bytes - Viewed (0) -
src/net/http/internal/chunked_test.go
} } func TestChunkEndReadError(t *testing.T) { readErr := fmt.Errorf("chunk end read error") r := NewChunkedReader(io.MultiReader(strings.NewReader("4\r\nabcd"), iotest.ErrReader(readErr))) if _, err := io.ReadAll(r); err != readErr { t.Errorf("expected %v, got %v", readErr, err) } } func TestChunkReaderTooMuchOverhead(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jan 04 20:45:19 UTC 2024 - 8K bytes - Viewed (0) -
src/testing/iotest/reader_test.go
}{ {"nil error", nil}, {"non-nil error", errors.New("io failure")}, {"io.EOF", io.EOF}, } for _, tt := range cases { tt := tt t.Run(tt.name, func(t *testing.T) { n, err := ErrReader(tt.err).Read(nil) if err != tt.err { t.Fatalf("Error mismatch\nGot: %v\nWant: %v", err, tt.err) } if n != 0 { t.Fatalf("Byte count mismatch: got %d want 0", n) } }) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 07 07:03:10 UTC 2022 - 6.1K bytes - Viewed (0) -
internal/s3select/csv/reader_contrib_test.go
} if fields != c.totalFields { t.Errorf("Case %d failed: expected %v results %v", i, c.totalFields, fields) } }) } } type errReader struct { err error } func (e errReader) Read(p []byte) (n int, err error) { return 0, e.err } func TestReadFailures(t *testing.T) { customErr := errors.New("unable to read file :(") cases := []struct {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 38.5K bytes - Viewed (0) -
src/archive/tar/strconv.go
if !ok { return "", "", s, ErrHeader } // Parse the first token as a decimal integer. n, perr := strconv.ParseInt(nStr, 10, 0) // Intentionally parse as native int if perr != nil || n < 5 || n > int64(len(s)) { return "", "", s, ErrHeader } n -= int64(len(nStr) + 1) // convert from index in s to index in rest if n <= 0 { return "", "", s, ErrHeader }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 01 14:28:42 UTC 2023 - 9K bytes - Viewed (0) -
src/compress/zlib/reader.go
// ErrDictionary is returned when reading ZLIB data that has an invalid dictionary. ErrDictionary = errors.New("zlib: invalid dictionary") // ErrHeader is returned when reading ZLIB data that has an invalid header. ErrHeader = errors.New("zlib: invalid header") ) type reader struct { r flate.Reader decompressor io.ReadCloser digest hash.Hash32 err error
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 13 23:20:03 UTC 2023 - 4.7K bytes - Viewed (0) -
src/archive/tar/reader_test.go
err: ErrHeader, }, { file: "testdata/issue10968.tar", err: ErrHeader, }, { file: "testdata/issue11169.tar", err: ErrHeader, }, { file: "testdata/issue12435.tar", err: ErrHeader, }, { // Ensure that we can read back the original Header as written with // a buggy pre-Go1.8 tar.Writer. file: "testdata/invalid-go17.tar", headers: []*Header{{
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Nov 21 21:14:38 UTC 2022 - 47.1K bytes - Viewed (0) -
src/archive/tar/reader.go
} hdr.Xattrs[k[len(paxSchilyXattr):]] = v } } if err != nil { return ErrHeader } } hdr.PAXRecords = paxHdrs return nil } // parsePAX parses PAX headers. // If an extended header (type 'x') is invalid, ErrHeader is returned. func parsePAX(r io.Reader) (map[string]string, error) { buf, err := readSpecialFile(r) if err != nil { return nil, err
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 08 01:59:14 UTC 2024 - 26.8K bytes - Viewed (0)