(change vault.ChangeEvent)
| 313 | } |
| 314 | |
| 315 | func (w *Watcher) broadcast(change vault.ChangeEvent) { |
| 316 | w.mu.Lock() |
| 317 | for ch := range w.subs { |
| 318 | select { |
| 319 | case ch <- change: |
| 320 | default: |
| 321 | } |
| 322 | } |
| 323 | w.mu.Unlock() |
| 324 | } |
no outgoing calls
no test coverage detected