- Sort Score
- Num 10 results
- Language All
Results 1 - 5 of 5 for readerFor (0.27 seconds)
-
internal/s3select/jstream/errors.go
msg string // description of error context string // additional error context pos errPos atChar byte readerErr error // underlying reader error, if any } // ReaderErr returns the underlying error. func (e DecoderError) ReaderErr() error { return e.readerErr } // Error returns a string representation of the error. func (e DecoderError) Error() string {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon Sep 23 19:35:41 GMT 2024 - 1.3K bytes - Click Count (0) -
src/bytes/reader_test.go
want string wantpos int64 readerr error seekerr string }{ {seek: io.SeekStart, off: 0, n: 20, want: "0123456789"}, {seek: io.SeekStart, off: 1, n: 1, want: "1"}, {seek: io.SeekCurrent, off: 1, wantpos: 3, n: 2, want: "34"}, {seek: io.SeekStart, off: -1, seekerr: "bytes.Reader.Seek: negative position"}, {seek: io.SeekStart, off: 1 << 33, wantpos: 1 << 33, readerr: io.EOF},Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Mon Dec 13 18:45:54 GMT 2021 - 8K bytes - Click Count (0) -
internal/s3select/jstream/scanner_test.go
var i int r := bytes.NewReader(data) scanner := newScanner(r) for scanner.pos < atomic.LoadInt64(&scanner.end) { c := scanner.next() if scanner.readerErr != nil { t.Fatal(scanner.readerErr) } if c != data[i] { t.Fatalf("expected %s, got %s", string(data[i]), string(c)) } t.Logf("pos=%d remaining=%d (%s)", i, r.Len(), string(c)) i++ } }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 3.1K bytes - Click Count (0) -
internal/s3select/jstream/scanner.go
end int64 buf [chunk + 1]byte // internal buffer (with a lookback size of 1) nbuf [chunk]byte // next internal buffer fillReq chan struct{} fillReady chan int64 readerErr error // underlying reader error, if any } func newScanner(r io.Reader) *scanner { sr := &scanner{ end: maxInt, fillReq: make(chan struct{}), fillReady: make(chan int64), } go func() {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon Sep 23 19:35:41 GMT 2024 - 2.5K bytes - Click Count (0) -
internal/s3select/jstream/decoder_test.go
if err == nil { t.Fatalf("missing expected decoder error") } derr, ok := err.(DecoderError) if !ok { t.Fatalf("expected error of type DecoderError, got %T", err) } if derr.ReaderErr() == nil { t.Fatalf("missing expected underlying reader error") } } func TestDecoderMaxDepth(t *testing.T) { tests := []struct { input string maxDepth int mustFail bool }{Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 6.6K bytes - Click Count (0)