add comment

akuzni2 · akuzni2 · commit bf2419e0d11a · 2026-01-29T16:21:35.000-05:00
diff --git a/go/stream.go b/go/stream.go
@@ -137,6 +137,8 @@ func (c *client) newStream(ctx context.Context, httpClient *http.Client, feedIDs
 						return
 					}
 					go s.monitorConn(conn)
+					// Lock is aquired here to prevent race condition with Close() occuring
+					// during this background reconnect attempt
 					s.closingMutex.Lock()
 					s.conns = append(s.conns, conn)
 					s.closingMutex.Unlock()

Original file line number	Diff line number	Diff line change
`@@ -137,6 +137,8 @@ func (c client) newStream(ctx context.Context, httpClient http.Client, feedIDs`
`137`	`137`	`return`
`138`	`138`	`}`
`139`	`139`	`go s.monitorConn(conn)`
	`140`	`+ // Lock is aquired here to prevent race condition with Close() occuring`
	`141`	`+ // during this background reconnect attempt`
`140`	`142`	`s.closingMutex.Lock()`
`141`	`143`	`s.conns = append(s.conns, conn)`
`142`	`144`	`s.closingMutex.Unlock()`