Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for emitAny (0.06 sec)

  1. 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)
Back to top