handle req queue close

ipfs · Jan 29, 2025 · f096fbc · f096fbc
1 parent 6b3efd0
commit f096fbc
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/bitswap/client/internal/messagequeue/messagequeue.go b/bitswap/client/internal/messagequeue/messagequeue.go
@@ -503,7 +503,10 @@ func (mq *MessageQueue) runQueue() {
 			workScheduled = time.Time{}
 			newWork = mq.sendIfReady()
 
-		case req := <-requests:
+		case req, ok := <-requests:
+			if !ok {
+				return
+			}
 			newWork = req()
 
 		case res := <-mq.responses: