From 369e8808504b8378b9864a033c8efa0e3e26b8d0 Mon Sep 17 00:00:00 2001
From: Nan Yan <625518543@qq.com>
Date: Fri, 10 May 2024 11:51:21 +0800
Subject: [PATCH] fix: continue leader failed should close leader component

---
 fastflow.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/fastflow.go b/fastflow.go
index d7f0904..aeee7dc 100644
--- a/fastflow.go
+++ b/fastflow.go
@@ -152,7 +152,7 @@ func (l *LeaderChangedHandler) Handle(cxt context.Context, e goevent.Event) {
 		log.Println("leader initial")
 	}
 	// continue leader failed
-	if !lcEvent.IsLeader && len(l.leaderCloser) == 0 {
+	if !lcEvent.IsLeader && len(l.leaderCloser) != 0 {
 		l.Close()
 	}
 }