Assumes the caller holds the lock.
(chanId int)
| 283 | |
| 284 | // Assumes the caller holds the lock. |
| 285 | func (e *EventEmitter) unsubscribeInner(chanId int) { |
| 286 | close(e.chans[chanId]) |
| 287 | delete(e.chans, chanId) |
| 288 | } |
| 289 | |
| 290 | func (e *EventEmitter) Unsubscribe(chanId int) { |
| 291 | e.mu.Lock() |
no outgoing calls
no test coverage detected