From c33ae5fa913f698f3244a21114b11e474bb879cc Mon Sep 17 00:00:00 2001
From: Hoon <48665813+sh-cha@users.noreply.github.com>
Date: Thu, 23 Jan 2025 14:28:37 +0900
Subject: [PATCH] fix waiting pending txs loop break logic (#66)

---
 node/broadcaster/broadcaster.go | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/node/broadcaster/broadcaster.go b/node/broadcaster/broadcaster.go
index 97391c6..4d34942 100644
--- a/node/broadcaster/broadcaster.go
+++ b/node/broadcaster/broadcaster.go
@@ -160,19 +160,20 @@ func (b *Broadcaster) loadPendingTxs(ctx types.Context, stage types.BasicDB, las
 		pollingTimer := time.NewTicker(ctx.PollingInterval())
 		defer pollingTimer.Stop()
 
+	WAITLOOP:
 		for {
+			if len(pendingTxs) == 0 {
+				return nil
+			}
+
 			select {
 			case <-ctx.Done():
 				return ctx.Err()
 			case <-timer.C:
-				break
+				break WAITLOOP
 			case <-pollingTimer.C:
 			}
 
-			if len(pendingTxs) == 0 {
-				return nil
-			}
-
 			txHash, err := hex.DecodeString(pendingTxs[0].TxHash)
 			if err != nil {
 				return err