Method CleanupLoop

internal/bridge/taskmanager.go:340–351

CleanupLoop runs Cleanup periodically until ctx is cancelled.

(done <-chan struct{}, maxAge time.Duration)

// CleanupLoop runs Cleanup periodically until ctx is cancelled.
func (tm *TaskManager) CleanupLoop(done <-chan struct{}, maxAge time.Duration) {
	ticker := time.NewTicker(60 * time.Second)
	defer ticker.Stop()
	for {
		select {
		case <-ticker.C:
			tm.Cleanup(maxAge)
		case <-done:
			return
		}
	}
}