Method ForEach

pkg/cache/postgres/object.go:167–183

ForEach implements the required method to iterate over each object.

(cb func(obj plumbing.EncodedObject) error)

// ForEach implements the required method to iterate over each object.
func (iter *EncodedObjectIter) ForEach(cb func(obj plumbing.EncodedObject) error) error {
	for {
		obj, err := iter.Next()
		if err != nil {
			if err == io.EOF {
				return nil
			}
			return err
		}
		if err := cb(obj); err != nil {
			if err == storer.ErrStop {
				return nil
			}
			return err
		}
	}
}

// Close is a placeholder to satisfy the EncodedObjectIter interface.
func (iter *EncodedObjectIter) Close() {