Method Close

coderd/x/chatd/chatd.go:9869–9878

Close stops the processor and waits for it to finish.

()

// Close stops the processor and waits for it to finish.
func (p *Server) Close() error {
	if unsub := p.configCacheUnsubscribe; unsub != nil {
		p.configCacheUnsubscribe = nil
		unsub()
	}
	p.cancel()
	p.wg.Wait()
	p.drainInflight()
	return nil
}

// drainInflight waits for all in-flight operations to complete.
// It acquires inflightMu to prevent processOnce from spawning