Function NewLocalDownloadServiceWithInput

internal/core/local_service.go:101–144

NewLocalDownloadServiceWithInput creates a service using a provided input channel. If inputCh is nil, a new buffered channel is created.

(pool *download.WorkerPool, inputCh chan interface{})

// NewLocalDownloadServiceWithInput creates a service using a provided input channel.
// If inputCh is nil, a new buffered channel is created.
func NewLocalDownloadServiceWithInput(pool *download.WorkerPool, inputCh chan interface{}) *LocalDownloadService {
	if inputCh == nil {
		inputCh = make(chan interface{}, 100)
	}
	s := &LocalDownloadService{
		Pool:      pool,
		InputCh:   inputCh,
		listeners: make([]chan interface{}, 0),
	}

	// Load initial settings
	if s.settings, _ = config.LoadSettings(); s.settings == nil {
		s.settings = config.DefaultSettings()
	}
	if pool != nil && s.settings != nil {
		runtime := s.settings.ToRuntimeConfig()
		pool.SetGlobalRateLimit(runtime.GlobalRateLimitBps)
		pool.SetDefaultDownloadRateLimit(runtime.DefaultDownloadRateLimitBps)
	}

	// Lifecycle
	ctx, cancel := context.WithCancel(context.Background())
	s.ctx = ctx
	s.cancel = cancel

	// Start broadcaster
	s.broadcastWG.Add(1)
	go func() {
		defer s.broadcastWG.Done()
		s.broadcastLoop()
	}()

	// Start progress reporter
	if pool != nil {
		s.reportTicker = time.NewTicker(ReportInterval)
		s.reportWG.Add(1)
		go func() {
			defer s.reportWG.Done()
			s.reportProgressLoop()
		}()
	}

	return s
}

func (s *LocalDownloadService) broadcastLoop() {
	for msg := range s.InputCh {