fix deadlock in mockPubSub

go-pkgz · May 13, 2020 · b9b9add · b9b9add
1 parent 9a2b157
commit b9b9add
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/cache_test.go b/cache_test.go
@@ -671,7 +671,8 @@ func (m *mockPubSub) Subscribe(fn func(fromID string, key string)) error {
 func (m *mockPubSub) Publish(fromID, key string) error {
 	m.calledKeys = append(m.calledKeys, key)
 	for _, fn := range m.fns {
-		fn(fromID, key)
+		// run in goroutine to prevent deadlock
+		go fn(fromID, key)
 		log.Println("!!!", fromID, key)
 	}
 	return nil