fix close monitor heartbeat (#5)

This commit is contained in:
motiisr
2021-05-30 15:41:10 +03:00
committed by GitHub
parent da4496c0a1
commit c766df8bf1
2 changed files with 2 additions and 1 deletions

1
.gitignore vendored Normal file
View File

@@ -0,0 +1 @@
.idea

View File

@@ -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())
}