File tree Expand file tree Collapse file tree 2 files changed +3
-2
lines changed Expand file tree Collapse file tree 2 files changed +3
-2
lines changed Original file line number Diff line number Diff line change 77package mongo
88
99import (
10+ "context"
1011 "encoding/json"
1112 "io/ioutil"
1213 "os"
@@ -70,7 +71,7 @@ var retryMonitoredTopologyOnce sync.Once
7071var retryStartedChan = make (chan * event.CommandStartedEvent , 100 )
7172
7273var retryMonitor = & event.CommandMonitor {
73- Started : func (cse * event.CommandStartedEvent ) {
74+ Started : func (ctx context. Context , cse * event.CommandStartedEvent ) {
7475 retryStartedChan <- cse
7576 },
7677}
Original file line number Diff line number Diff line change @@ -104,7 +104,7 @@ type transError struct {
104104var transStartedChan = make (chan * event.CommandStartedEvent , 100 )
105105
106106var transMonitor = & event.CommandMonitor {
107- Started : func (cse * event.CommandStartedEvent ) {
107+ Started : func (ctx context. Context , cse * event.CommandStartedEvent ) {
108108 //fmt.Printf("STARTED: %v\n", cse)
109109 transStartedChan <- cse
110110 },
You can’t perform that action at this time.
0 commit comments