> fix send event error if watcher stopped

merbridge · Oct 21, 2022 · 37715d1 · 37715d1
1 parent ee5995c
commit 37715d1
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/process_watcher.go b/process_watcher.go
@@ -73,9 +73,11 @@ func (pw *processWatcher) Events() <-chan WatchEvent {
 
 func (pw *processWatcher) sendEvents(e WatchEvent) {
 	select {
-	case pw.events <- e:
 	case <-pw.stop:
+		return
+	default:
 	}
+	pw.events <- e
 }
 
 func (pw *processWatcher) Start() error {