From 9693665cce97725f993ad72c53205846d1022653 Mon Sep 17 00:00:00 2001
From: AlexandrosKyriakakis <alexandros.kyriakakis@alpaca.markets>
Date: Wed, 31 Jan 2024 18:13:57 +0200
Subject: [PATCH] refactor send queued

---
 session.go | 19 +++++--------------
 1 file changed, 5 insertions(+), 14 deletions(-)

diff --git a/session.go b/session.go
index e76e596f8..db5198e04 100644
--- 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()
 }