- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for emitAny (0.04 sec)
-
internal/s3select/jstream/decoder.go
func (d *Decoder) decode() { defer close(d.metaCh) d.skipSpaces() for d.remaining() > 0 { _, err := d.emitAny() if err != nil { d.err = err break } d.skipSpaces() } } func (d *Decoder) emitAny() (interface{}, error) { if d.pos >= atomic.LoadInt64(&d.end) { return nil, d.mkError(ErrUnexpectedEOF) } offset := d.pos - 1
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 13.5K bytes - Viewed (0)