diff --git a/raft.go b/raft.go index 4fcb95f7..439fe6e2 100644 --- a/raft.go +++ b/raft.go @@ -434,6 +434,11 @@ func (r *Raft) runLeader() { select { case notify <- true: case <-r.shutdownCh: + // make sure push to the notify channel ( if given ) + select { + case notify <- true: + default: + } } }