add emit config update helper (#655)

livekit · Mar 13, 2024 · 8d755b4 · 8d755b4
1 parent 912f0cf
commit 8d755b4
Showing 1 changed file with 9 additions and 5 deletions.
diff --git a/utils/configobserver.go b/utils/configobserver.go
@@ -57,6 +57,14 @@ func (c *ConfigObserver[T]) Close() {
 	}
 }
 
+func (c *ConfigObserver[T]) EmitConfigUpdate(conf *T) {
+	c.mu.Lock()
+	defer c.mu.Unlock()
+	for e := c.cbs.Front(); e != nil; e = e.Next() {
+		go e.Value.(func(*T))(conf)
+	}
+}
+
 func (c *ConfigObserver[T]) Observe(cb func(*T)) func() {
 	if c == nil {
 		return func() {}
@@ -106,11 +114,7 @@ func (c *ConfigObserver[T]) reload(path string) error {
 		return err
 	}
 
-	c.mu.Lock()
-	defer c.mu.Unlock()
-	for e := c.cbs.Front(); e != nil; e = e.Next() {
-		go e.Value.(func(*T))(conf)
-	}
+	c.EmitConfigUpdate(conf)
 	return nil
 }