feat: add any subscriber

Author: robinbraemer

manager_internal.go

@@ -171,16 +171,24 @@ func (m *manager) Fire(event Event) {
 	m.fire(event)
 }
 
+var anyType = typeOf(any(nil))
+
 func (m *manager) fire(event Event) {
 	eventType := typeOf(event)
+
 	m.mu.RLock()
 	list := m.subscribers[eventType]
+	anyList := m.subscribers[anyType]
 	m.mu.RUnlock()
 
+	m.fireSubscribers(event, anyList)
+	m.fireSubscribers(event, list)
+}
+
+func (m *manager) fireSubscribers(event Event, list *subscriberList) {
 	if list == nil {
 		return
 	}
-
 	list.wg.Add(1)
 	defer list.wg.Done()
 

manager_test.go

@@ -42,9 +42,15 @@ func TestPriorityAndCorrectType(t *testing.T) {
 		noPtr = true
 	})
 
+	var calledAny int
+	m.Subscribe(any(nil), 10, func(e Event) {
+		calledAny++
+	})
+
 	e := &myEvent{s: "_"}
 	m.Fire(e)
 	require.False(t, noPtr)
 	require.Equal(t, "_abc", e.s)
 	require.True(t, m.HasSubscriber(&myEvent{}))
+	require.Equal(t, calledAny, 1)
 }