(ctx context.Context)
| 126 | } |
| 127 | |
| 128 | func (b *bookmark[T]) peekID(ctx context.Context) (common.ID, error) { |
| 129 | nextID, err := b.iter.peekNextID(ctx) |
| 130 | if !errors.Is(err, util.ErrUnsupported) { |
| 131 | return nextID, err |
| 132 | } |
| 133 | |
| 134 | id, _, err := b.current(ctx) |
| 135 | return id, err |
| 136 | } |
| 137 | |
| 138 | func (b *bookmark[T]) current(ctx context.Context) (common.ID, T, error) { |
| 139 | if b.currentErr != nil { |
no test coverage detected