Merge pull request #880 from ekcasey/fix-eventstream-race-condition

Fixes race condition in EventStream
asynkron · Aug 12, 2023 · 3987052 · 3987052
2 parents c163360 + 1bae8af
commit 3987052
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/eventstream/eventstream.go b/eventstream/eventstream.go
@@ -111,7 +111,9 @@ func (es *EventStream) Publish(evt interface{}) {
 
 // Returns an integer that represents the current number of subscribers to the stream
 func (es *EventStream) Length() int32 {
-	return atomic.LoadInt32(&es.counter)
+	es.RLock()
+	defer es.RUnlock()
+	return es.counter
 }
 
 // Subscription is returned from the Subscribe function.