in experimental/blobs.go [49:68]
func (b blobsData) sweep() error {
jg := jobsRunner.group()
for _, blob_ := range b {
blob := blob_
jg.dispatch(func() error {
if blob.references > 0 {
return nil
}
err := deleteFile(blob.path(), blob.size)
if err != nil {
return err
}
return nil
})
}
return jg.finish()
}