Function startAsyncUpdateHandler

ftv.go:42–88

startAsyncUpdateHandler manages UI updates during async loading

(updateChan <-chan bool, doneChan <-chan error)

// startAsyncUpdateHandler manages UI updates during async loading
func startAsyncUpdateHandler(updateChan <-chan bool, doneChan <-chan error) {
	go func() {
		ticker := time.NewTicker(20 * time.Millisecond)
		defer ticker.Stop()

		loadComplete := false
		for !loadComplete {
			select {
			case <-updateChan:
				// Update available - will be handled by ticker
			case err := <-doneChan:
				loadComplete = true
				if err != nil {
					fatalError(err)
				}
				// Final update
				app.QueueUpdateDraw(func() {
					drawBuffer(b, bufferTable)
					updateFooterWithStatus("Loaded " + strconv.Itoa(b.rowLen) + " rows")
				})
			case <-ticker.C:
				// Periodic UI update
				app.QueueUpdateDraw(func() {
					drawBuffer(b, bufferTable)

					// Keep cursor on first row if user hasn't moved it
					if !userMovedCursor {
						row, col := bufferTable.GetSelection()
						if row != 0 {
							bufferTable.Select(0, col)
						}
					}

					if loadProgress.TotalBytes > 0 {
						// Show progress bar for files
						percent := loadProgress.GetPercentage()
						progressBar := makeProgressBar(percent, 15)
						updateFooterWithStatus(fmt.Sprintf("Loading... %s", progressBar))
					} else {
						// Show row count for pipes (no file size)
						updateFooterWithStatus("Loading... " + strconv.Itoa(b.rowLen) + " rows")
					}
				})
			}
		}
	}()
}

// loadDataAsync starts async loading and waits for initial data
func loadDataAsync(loader func(*Buffer, chan<- bool, chan<- error), b *Buffer) (chan bool, chan error, error) {