Add waitgroup wait to keep plugin running until goroutine is ready

nginx · Sep 19, 2022 · d57a75c · d57a75c
1 parent 9fe1f95
commit d57a75c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/plugins/process_watcher.go b/src/plugins/process_watcher.go
@@ -62,6 +62,7 @@ func (pw *ProcessWatcher) Info() *core.Info {
 
 func (pw *ProcessWatcher) Close() {
 	log.Info("ProcessWatcher is wrapping up")
+	pw.wg.Wait()
 }
 
 func (pw *ProcessWatcher) Process(message *core.Message) {}