Method run

internal/lsp/progress.go:110–196

run is the persistent goroutine that processes all progress events. It owns all mutable state: no external synchronization needed.

()

// run is the persistent goroutine that processes all progress events.
// It owns all mutable state: no external synchronization needed.
func (p *projectLoadingProgress) run() {
	var (
		loading collections.OrderedMap[string, int]
		token   string // current token; empty if no progress active
		tokenID int
		begun   bool // whether "begin" has been sent for the current token
	)

	var delay *time.Timer
	delayC := func() <-chan time.Time {
		if delay == nil {
			return nil
		}
		return delay.C
	}
	stopDelay := func() {
		if delay != nil {
			delay.Stop()
			delay = nil
		}
	}
	delayFired := false // true after the delay timer fires

	for {
		select {
		case ev := <-p.ch:
			text := p.reporter.localize(ev.message, ev.args...)
			if !ev.finish {
				count := loading.GetOrZero(text)
				loading.Set(text, count+1)
				if token == "" {
					tokenID++
					token = fmt.Sprintf("tsgo-loading-%d", tokenID)
					begun = false
					if p.delay <= 0 {
						delayFired = true
						p.reporter.createWorkDoneProgress(token)
					} else {
						delayFired = false
						delay = time.NewTimer(p.delay)
					}
				}
				if delayFired {
					begun = p.beginOrReport(token, text, begun)
				}
			} else {
				count := loading.GetOrZero(text)
				if count <= 1 {
					loading.Delete(text)
				} else {
					loading.Set(text, count-1)
				}
				if token == "" {
					continue
				}
				if loading.Size() == 0 {
					if begun {
						p.reporter.sendProgress(token, lsproto.WorkDoneProgressBeginOrReportOrEnd{