Method initQueue

kv/table/iterator.go:61–77

initQueue initializes the priority queue

()

// initQueue initializes the priority queue
func (m *mergedIterator) initQueue() {
	i := 0
	for _, it := range m.its {
		if it.HasNext() {
			m.pq = append(m.pq, &item{
				it:    it,
				key:   it.Key(),
				value: it.Value(),
				index: i,
			})
			i++
		}
	}
	if len(m.pq) > 0 {
		heap.Init(&m.pq)
	}
}

// HasNext returns if the iteration has more element.
// It returns false if the iterator is exhausted.