()
| 78 | } |
| 79 | |
| 80 | func (c *DalCursorIterator) batchedFetch() (interface{}, errors.Error) { |
| 81 | var elems []interface{} |
| 82 | for i := 1; ; i++ { |
| 83 | elem := reflect.New(c.elemType).Interface() |
| 84 | err := c.cursor.Scan(elem) |
| 85 | if err != nil { |
| 86 | return nil, errors.Convert(err) |
| 87 | } |
| 88 | elems = append(elems, elem) |
| 89 | if i == c.batchSize || !c.HasNext() { |
| 90 | break |
| 91 | } |
| 92 | } |
| 93 | return elems, nil |
| 94 | } |
| 95 | |
| 96 | // Close iterator |
| 97 | func (c *DalCursorIterator) Close() errors.Error { |