From 4afe8428c8c0bc7c76e3e04acf4b223854d1ceff Mon Sep 17 00:00:00 2001
From: aler9 <46489434+aler9@users.noreply.github.com>
Date: Thu, 3 Sep 2020 16:31:52 +0200
Subject: [PATCH] fix race condition

---
 path.go   | 2 +-
 source.go | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/path.go b/path.go
index 1043e6b5..e7ca05d6 100644
--- a/path.go
+++ b/path.go
@@ -59,7 +59,7 @@ func (pa *path) log(format string, args ...interface{}) {
 
 func (pa *path) onInit() {
 	if pa.source != nil {
-		go pa.source.run()
+		go pa.source.run(pa.source.state)
 	}
 
 	if pa.confp.RunOnInit != "" {
diff --git a/source.go b/source.go
index f7f038aa..1699e426 100644
--- a/source.go
+++ b/source.go
@@ -66,8 +66,8 @@ func newSource(p *program, path *path, confp *confPath) *source {
 
 func (s *source) isPublisher() {}
 
-func (s *source) run() {
-	s.applyState(s.state)
+func (s *source) run(initialState sourceState) {
+	s.applyState(initialState)
 
 outer:
 	for {