Broadcast unblocks all goroutines currently waiting on C().
()
| 264 | |
| 265 | // Broadcast unblocks all goroutines currently waiting on C(). |
| 266 | func (w *waker) Broadcast() { |
| 267 | w.mu.Lock() |
| 268 | defer w.mu.Unlock() |
| 269 | close(w.ch) |
| 270 | w.ch = make(chan struct{}) |
| 271 | } |
| 272 | |
| 273 | // Client owns the session map and the long-poll loop. |
| 274 | type Client struct { |
no outgoing calls
no test coverage detected