We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0ffab78 commit 53b6815Copy full SHA for 53b6815
x/mongo/driver/topology/server.go
@@ -473,19 +473,11 @@ func (s *Server) update() {
473
checkNow := s.checkNow
474
done := s.done
475
476
- var doneOnce bool
477
defer func() {
478
- if r := recover(); r != nil {
479
- if doneOnce {
480
- return
481
- }
482
- // We keep this goroutine alive attempting to read from the done channel.
483
- <-done
484
+ _ = recover()
485
}()
486
487
closeServer := func() {
488
- doneOnce = true
489
s.subLock.Lock()
490
for id, c := range s.subscribers {
491
close(c)
0 commit comments