fix: continue leader failed should close leader component

ShiningRush · May 10, 2024 · 369e880 · 369e880
1 parent 6ddfd94
commit 369e880
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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()
 	}
 }