refactor send queued

quickfixgo · Jan 31, 2024 · 9693665 · 9693665
1 parent 21384e6
commit 9693665
Showing 1 changed file with 5 additions and 14 deletions.
diff --git a/session.go b/session.go
@@ -351,23 +351,14 @@ func (s *session) persist(seqNum int, msgBytes []byte) error {
 }
 
 func (s *session) sendQueued() {
-	var (
-		sent         bool
-		indexBlocked int
-	)
-
 	for i, msgBytes := range s.toSend {
-		sent = s.sendBytes(msgBytes)
-		if !sent {
-			indexBlocked = i
-			break
+		if !s.sendBytes(msgBytes) {
+			s.toSend = s.toSend[i:]
+			s.notifyMessageOut()
+			return
 		}
 	}
-	if !sent {
-		s.toSend = s.toSend[indexBlocked:]
-		s.notifyMessageOut()
-		return
-	}
+
 	s.dropQueued()
 }