remove race from test

Author: akuzni2

.github/workflows/go-tests.yml

@@ -23,6 +23,7 @@ jobs:
           go-version: "1.24"
           cache-dependency-path: go/go.sum
 
+      # Runs test with shuffle and count to expose flaky tests.
       - name: Run tests
         working-directory: go
-        run: go test -race ./...
+        run: go test -count=10 -shuffle=on ./...

go/stream.go

@@ -136,11 +136,13 @@ func (c *client) newStream(ctx context.Context, httpClient *http.Client, feedIDs
 					if err != nil {
 						return
 					}
-					s.addConn(conn)
+					go s.monitorConn(conn)
+					s.conns = append(s.conns, conn)
 				}()
 				continue
 			}
-			s.addConn(conn)
+			go s.monitorConn(conn)
+			s.conns = append(s.conns, conn)
 		}
 
 		// Only fail if we couldn't connect to ANY origins
@@ -164,16 +166,6 @@ func (c *client) newStream(ctx context.Context, httpClient *http.Client, feedIDs
 	return s, nil
 }
 
-// addConn adds a connection to the monitoring goroutine aquires the closingMutex to append the connection
-// to the stream's connection list safely. It uses the closingMutex to prevent a race conditions with Close()
-// but is also using this mutex to prevent race conditions with other goroutines appending to conns.
-func (s *stream) addConn(conn *wsConn) {
-	go s.monitorConn(conn)
-	s.closingMutex.Lock()
-	s.conns = append(s.conns, conn)
-	s.closingMutex.Unlock()
-}
-
 func (s *stream) pingConn(ctx context.Context, conn *wsConn) {
 	ticker := time.NewTicker(time.Second * 2)
 	defer ticker.Stop()