From c766df8bf1aa76a18678b736e86e7539138d6f00 Mon Sep 17 00:00:00 2001 From: motiisr Date: Sun, 30 May 2021 15:41:10 +0300 Subject: [PATCH] fix close monitor heartbeat (#5) --- .gitignore | 1 + supervisor.go | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) create mode 100644 .gitignore diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..485dee6 --- /dev/null +++ b/.gitignore @@ -0,0 +1 @@ +.idea diff --git a/supervisor.go b/supervisor.go index 3fd2630..e76c8fd 100644 --- a/supervisor.go +++ b/supervisor.go @@ -307,7 +307,6 @@ func readerToChan(producer ProduceFn, out chan<- *interface{}, closeWhenDone, st // // When stopC closes, this function will exit immediately. func monitorHeartBeat(idleTimeout time.Duration, heartbeat, isMonitorClosed, stopC chan bool, stop func() error, notifyEvent func(string, ...interface{})) { - defer close(isMonitorClosed) t := time.NewTimer(idleTimeout) defer t.Stop() @@ -333,6 +332,7 @@ func monitorHeartBeat(idleTimeout time.Duration, heartbeat, isMonitorClosed, sto } } + close(isMonitorClosed) if err := stop(); err != nil { notifyEvent("StopError", err.Error()) }