diff --git a/hub/hub.go b/hub/hub.go index ab4a3cf..92b1dba 100644 --- a/hub/hub.go +++ b/hub/hub.go @@ -54,9 +54,7 @@ func (h *Hub) Sub(s *Subscription) { } } - h.lock.Lock() h.subscribers = append(h.subscribers, s) - h.lock.Unlock() } func (h *Hub) Info() map[string]map[string]uint {