Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for newCountUpReader (0.27 sec)

  1. internal/s3select/progress.go

    	atomic.AddInt64(&r.bytesRead, int64(n))
    	return n, err
    }
    
    func (r *countUpReader) BytesRead() int64 {
    	if r == nil {
    		return 0
    	}
    	return atomic.LoadInt64(&r.bytesRead)
    }
    
    func newCountUpReader(reader io.Reader) *countUpReader {
    	return &countUpReader{
    		reader: reader,
    	}
    }
    
    type progressReader struct {
    	rc              io.ReadCloser
    	scannedReader   *countUpReader
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 4.3K bytes
    - Viewed (0)
Back to top