in tools/mc2bq/pkg/export/export.go [228:253]
func (r *objectReader[T]) Read(buf []byte) (int, error) {
if len(buf) == 0 {
return 0, nil
}
if len(r.buf) == 0 {
asset, err := r.it.Next()
if errors.Is(err, iterator.Done) {
return 0, io.EOF
}
if err != nil {
return 0, err
}
r.buf, err = r.serializer(asset)
if err != nil {
return 0, err
}
r.objectsRead++
}
n := copy(buf, r.buf)
r.bytesRead += uint64(n)
r.buf = r.buf[n:]
return n, nil
}