use skipping

cheb0 · cheb0 · commit 1a31fa12ff67 · 2026-02-15T12:50:25.000+04:00
diff --git a/frac/processor/aggregator.go b/frac/processor/aggregator.go
@@ -406,7 +406,7 @@ func NewSourcedNodeIterator(sourced node.Sourced, ti tokenIndex, tids []uint32,
 
 func (s *SourcedNodeIterator) ConsumeTokenSource(lid uint32) (uint32, bool, error) {
 	for s.has && s.less(s.lastID, lid) {
-		s.lastID, s.lastSource, s.has = s.sourcedNode.NextSourced()
+		s.lastID, s.lastSource, s.has = s.sourcedNode.NextSourcedGeq(lid)
 	}
 
 	exists := s.has && s.lastID == lid

Original file line number	Diff line number	Diff line change
`@@ -406,7 +406,7 @@ func NewSourcedNodeIterator(sourced node.Sourced, ti tokenIndex, tids []uint32,`
`406`	`406`
`407`	`407`	`func (s *SourcedNodeIterator) ConsumeTokenSource(lid uint32) (uint32, bool, error) {`
`408`	`408`	`for s.has && s.less(s.lastID, lid) {`
`409`		`- s.lastID, s.lastSource, s.has = s.sourcedNode.NextSourced()`
	`409`	`+ s.lastID, s.lastSource, s.has = s.sourcedNode.NextSourcedGeq(lid)`
`410`	`410`	`}`
`411`	`411`
`412`	`412`	`exists := s.has && s.lastID == lid`