addSubscriber registers a subscriber.
(s *subscriber)
| 177 | |
| 178 | // addSubscriber registers a subscriber. |
| 179 | func (cs *chatServer) addSubscriber(s *subscriber) { |
| 180 | cs.subscribersMu.Lock() |
| 181 | cs.subscribers[s] = struct{}{} |
| 182 | cs.subscribersMu.Unlock() |
| 183 | } |
| 184 | |
| 185 | // deleteSubscriber deletes the given subscriber. |
| 186 | func (cs *chatServer) deleteSubscriber(s *subscriber) { |