- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for newProgressReader (0.61 sec)
-
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,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Oct 18 15:44:36 GMT 2021 - 4.2K bytes - Viewed (0) -
internal/s3select/select.go
if err != nil { return err } var rc io.ReadCloser = rsc if length != -1 { rc = newLimitedReadCloser(rsc, length) } s3Select.progressReader, err = newProgressReader(rc, s3Select.Input.CompressionType) if err != nil { rsc.Close() return err } s3Select.recordReader, err = csv.NewReader(s3Select.progressReader, &s3Select.Input.CSVArgs) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0)