Method updateRunLocked

orca/producer.go:158–169

updateRunLocked is called whenever the run goroutine needs to be started / stopped / restarted due to: 1. the initial listener being registered, 2. the final listener being unregistered, or 3. the minimum registered interval changing.

()

// final listener being unregistered, or 3. the minimum registered interval
// changing.
func (p *producer) updateRunLocked() {
	if p.stop != nil {
		p.stop()
		p.stop = nil
	}
	if len(p.listeners) > 0 {
		var ctx context.Context
		ctx, p.stop = context.WithCancel(context.Background())
		p.stopped = make(chan struct{})
		go p.run(ctx, p.stopped, p.minInterval)
	}
}

// run manages the ORCA OOB stream on the subchannel.
func (p *producer) run(ctx context.Context, done chan struct{}, interval time.Duration) {