fixed: dataConfig每次只接收1个事件的问题

suxing9980 · Nov 10, 2023 · 2687798 · 2687798
1 parent 8765355
commit 2687798
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/components/data-config/source_file.go b/components/data-config/source_file.go
@@ -54,11 +54,6 @@ func (f *SourceFile) Init(_ IDataConfig) {
 
 	// new watcher
 	go f.newWatcher()
-
-	err = f.watcher.Start(time.Duration(f.ReloadTime) * time.Millisecond)
-	if err != nil {
-		clog.Panic(err)
-	}
 }
 
 func (f *SourceFile) ReadBytes(configName string) ([]byte, error) {
@@ -120,6 +115,11 @@ func (f *SourceFile) newWatcher() {
 			}
 		}
 	}()
+
+	err := f.watcher.Start(time.Duration(f.ReloadTime) * time.Millisecond)
+	if err != nil {
+		clog.Panic(err)
+	}
 }
 
 func (f *SourceFile) Stop() {