diff --git a/internal/events/events.go b/internal/events/events.go index ca49ec874..09523c324 100644 --- a/internal/events/events.go +++ b/internal/events/events.go @@ -103,7 +103,6 @@ type Subscription struct { mask EventType id int events chan Event - mutex sync.Mutex } var Default = NewLogger() @@ -153,7 +152,6 @@ func (l *Logger) Subscribe(mask EventType) *Subscription { mask: mask, id: l.nextID, events: make(chan Event, BufferSize), - mutex: sync.NewMutex(), } l.nextID++ l.subs[s.id] = s @@ -172,9 +170,6 @@ func (l *Logger) Unsubscribe(s *Subscription) { } func (s *Subscription) Poll(timeout time.Duration) (Event, error) { - s.mutex.Lock() - defer s.mutex.Unlock() - if debug { dl.Debugln("poll", timeout) }