- Sort Score
- Num 10 results
- Language All
Results 1 - 1 of 1 for newCountUpReader (0.25 seconds)
-
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
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 22 00:33:43 GMT 2024 - 4.3K bytes - Click Count (0)