diff --git a/pkg/api/riterator.go b/pkg/api/riterator.go index 00d2d45..2e0d611 100644 --- a/pkg/api/riterator.go +++ b/pkg/api/riterator.go @@ -92,7 +92,7 @@ func (ri *rIterator) fillBuf() error { q.Limit = min(100, ri.baseQuery.Limit) q.StartID = ri.nextID ri.buf = nil - mr, err := ri.ls.QueryRecords(ri.ctx, q) + mr, _, err := ri.ls.QueryRecords(ri.ctx, q) if err != nil { ri.cf(err) // cancel the context ctx ri.eof = true