Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for newProgressReader (0.11 sec)

  1. internal/s3select/progress.go

    	if pr == nil {
    		return 0, 0
    	}
    	return pr.scannedReader.BytesRead(), pr.processedReader.BytesRead()
    }
    
    func newProgressReader(rc io.ReadCloser, compType CompressionType) (*progressReader, error) {
    	if rc == nil {
    		return nil, errors.New("newProgressReader: nil reader provided")
    	}
    	scannedReader := newCountUpReader(rc)
    	pr := progressReader{
    		rc:            rc,
    		scannedReader: scannedReader,
    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