deleteSubscriber deletes the given subscriber.
(s *subscriber)
| 184 | |
| 185 | // deleteSubscriber deletes the given subscriber. |
| 186 | func (cs *chatServer) deleteSubscriber(s *subscriber) { |
| 187 | cs.subscribersMu.Lock() |
| 188 | delete(cs.subscribers, s) |
| 189 | cs.subscribersMu.Unlock() |
| 190 | } |
| 191 | |
| 192 | func writeTimeout(ctx context.Context, timeout time.Duration, c *websocket.Conn, msg []byte) error { |
| 193 | ctx, cancel := context.WithTimeout(ctx, timeout) |