fix the data race

Author: codemodify

manager-emit.go

@@ -4,8 +4,8 @@ import "encoding/json"
 
 // Emit - informs all subscribers about the event
 func (thisRef *Manager) Emit(eventName string) {
-	thisRef.eventsMutex.RLock()
-	defer thisRef.eventsMutex.RUnlock()
+	thisRef.eventsMutex.Lock()
+	defer thisRef.eventsMutex.Unlock()
 
 	thisRef.addEventIfNotExists(eventName)
 
@@ -17,8 +17,8 @@ func (thisRef *Manager) Emit(eventName string) {
 
 // EmitWithData - informs all subscribers about the event with data
 func (thisRef *Manager) EmitWithData(eventName string, data []byte, autoMarshal ...bool) {
-	thisRef.eventsMutex.RLock()
-	defer thisRef.eventsMutex.RUnlock()
+	thisRef.eventsMutex.Lock()
+	defer thisRef.eventsMutex.Unlock()
 
 	thisRef.addEventIfNotExists(eventName)
 

manager-helpers.go

@@ -17,8 +17,8 @@ func (thisRef *Manager) addEventIfNotExists(eventName string) {
 }
 
 func (thisRef *Manager) addSubscriberIfNotExists(eventName string, eventHandler Handler, shouldCallOnce bool) bool {
-	// thisRef.eventsMutex.RLock()
-	// defer thisRef.eventsMutex.RUnlock()
+	// thisRef.eventsMutex.Lock()
+	// defer thisRef.eventsMutex.Unlock()
 
 	// 1. Check if delegate for the event already there, assumes map-key exists
 	var alreadyThere = false
@@ -45,8 +45,8 @@ func (thisRef *Manager) addSubscriberIfNotExists(eventName string, eventHandler
 }
 
 func (thisRef *Manager) addSubscriberWithDataIfNotExists(eventName string, eventHandlerWithData HandlerWithData, shouldCallOnce bool) bool {
-	// thisRef.eventsMutex.RLock()
-	// defer thisRef.eventsMutex.RUnlock()
+	// thisRef.eventsMutex.Lock()
+	// defer thisRef.eventsMutex.Unlock()
 
 	// 1. Check if delegate for the event already there, assumes map-key exists
 	var alreadyThere = false

manager-off.go

@@ -6,8 +6,8 @@ import (
 
 // Off - remove a subscriber for an event
 func (thisRef *Manager) Off(eventName string, eventHandler Handler) {
-	thisRef.eventsMutex.RLock()
-	defer thisRef.eventsMutex.RUnlock()
+	thisRef.eventsMutex.Lock()
+	defer thisRef.eventsMutex.Unlock()
 
 	thisRef.addEventIfNotExists(eventName)
 
@@ -16,8 +16,8 @@ func (thisRef *Manager) Off(eventName string, eventHandler Handler) {
 
 // OffWithData - remove a subscriber with data for an event
 func (thisRef *Manager) OffWithData(eventName string, eventHandlerWithData HandlerWithData) {
-	thisRef.eventsMutex.RLock()
-	defer thisRef.eventsMutex.RUnlock()
+	thisRef.eventsMutex.Lock()
+	defer thisRef.eventsMutex.Unlock()
 
 	thisRef.addEventIfNotExists(eventName)
 

manager-on.go

@@ -2,8 +2,8 @@ package events
 
 // On - add a subscriber for an event
 func (thisRef *Manager) On(eventName string, eventHandler Handler, callOnce ...bool) {
-	thisRef.eventsMutex.RLock()
-	defer thisRef.eventsMutex.RUnlock()
+	thisRef.eventsMutex.Lock()
+	defer thisRef.eventsMutex.Unlock()
 
 	shouldCallOnce := false
 	if len(callOnce) > 0 {
@@ -16,8 +16,8 @@ func (thisRef *Manager) On(eventName string, eventHandler Handler, callOnce ...b
 
 // OnWithData - add a subscriber with data for an event
 func (thisRef *Manager) OnWithData(eventName string, eventHandlerWithData HandlerWithData, callOnce ...bool) {
-	thisRef.eventsMutex.RLock()
-	defer thisRef.eventsMutex.RUnlock()
+	thisRef.eventsMutex.Lock()
+	defer thisRef.eventsMutex.Unlock()
 
 	shouldCallOnce := false
 	if len(callOnce) > 0 {