changeSubStatus changes subscription status and sends events to all listeners. Lock should be held entering.
(status SubStatus)
| 5161 | // changeSubStatus changes subscription status and sends events |
| 5162 | // to all listeners. Lock should be held entering. |
| 5163 | func (s *Subscription) changeSubStatus(status SubStatus) { |
| 5164 | if s == nil { |
| 5165 | return |
| 5166 | } |
| 5167 | s.sendStatusEvent(status) |
| 5168 | s.status = status |
| 5169 | } |
| 5170 | |
| 5171 | // Unsubscribe will remove interest in the given subject. |
| 5172 | // |
no test coverage detected