- Sort Score
- Num 10 results
- Language All
Results 1 - 1 of 1 for newCountUpReader (0.1 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 Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 22 00:33:43 GMT 2024 - 4.3K bytes - Click Count (0)