Async Find With GORM

async_search.go

func getAllAsync[CH any](db *gorm.DB, pageSize int, ch chan<- *CH, wg *sync.WaitGroup, conds ...any) {
	wg.Add(1)

	defer close(ch)
	defer wg.Done()

	currentPage := 0
	for {
		rows := []*CH{}
		_ = db.
			Limit(pageSize).
			Offset(currentPage*pageSize).
			Find(&rows, conds...).Error

		if len(rows) == 0 {
			break
		}

		for _, row := range rows {
			ch <- row
		}

		currentPage++
	}
}

main.go

package main

func main() {
	var (
		pageSize = 10
		wg       = &sync.WaitGroup{}
		rowChan  = make(chan *map[string]any, pageSize)
	)

	go getAllAsync(db, pageSize, rowChan, wg)

	wg.Add(1)
	go func() {
		defer wg.Done()
		for row := range rowChan {
			fmt.Println(row)
		}
	}()

	wg.Wait()

	fmt.Println("Done")
}