fix: remove sub changes request when timeout happens

alpacahq · Mar 26, 2024 · 63e91f8 · 63e91f8
1 parent a9f58a9
commit 63e91f8
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/marketdata/stream/subscription.go b/marketdata/stream/subscription.go
@@ -264,11 +264,11 @@ func (c *client) handleSubChange(subscribe bool, changes subscriptions) error {
 		c.pendingSubChange = nil
 		// Drain the c.subChanges channel to avoid waiting size 1 channel when connection is lost.
 		// Please consider using connect/disconnect callbacks to avoid requesting sub change during disconnection.
-		// select {
-		// case <-c.subChanges:
-		// 	c.logger.Warnf("datav2stream: removed sub changes request due to timeout")
-		// default:
-		// }
+		select {
+		case <-c.subChanges:
+			c.logger.Warnf("datav2stream: removed sub changes request due to timeout")
+		default:
+		}
 	}
 
 	return ErrSubscriptionChangeTimeout