fix: fixed a memory leak caused by the commandMonitor example closure. (#1180)

elza2 · yuanyou · prestonvasquez · web-flow · commit fdb947408d3b · 2023-02-24T12:02:13.000-07:00
Co-authored-by: Preston Vasquez &lt;prestonvasquez@icloud.com&gt;
Co-authored-by: Preston Vasquez &lt;prestonvasquez@icloud.com&gt;

---------

Co-authored-by: yuanyou &lt;yuanyou@kezaihui.com&gt;
Co-authored-by: Preston Vasquez &lt;prestonvasquez@icloud.com&gt;
diff --git a/event/examples_test.go b/event/examples_test.go
@@ -32,12 +32,18 @@ func ExampleCommandMonitor() {
 				startedCommands[evt.RequestID],
 				evt.Reply,
 			)
+
+			// Empty "startedCommands" for the request ID to avoid a memory leak.
+			delete(startedCommands, evt.RequestID)
 		},
 		Failed: func(_ context.Context, evt *event.CommandFailedEvent) {
 			log.Printf("Command: %v Failure: %v\n",
 				startedCommands[evt.RequestID],
 				evt.Failure,
 			)
+
+			// Empty "startedCommands" for the request ID to avoid a memory leak.
+			delete(startedCommands, evt.RequestID)
 		},
 	}
 	clientOpts := options.Client().ApplyURI("mongodb://localhost:27017").SetMonitor(cmdMonitor)

Original file line number	Diff line number	Diff line change
`@@ -32,12 +32,18 @@ func ExampleCommandMonitor() {`
`32`	`32`	`startedCommands[evt.RequestID],`
`33`	`33`	`evt.Reply,`
`34`	`34`	`)`
	`35`	`+`
	`36`	`+ // Empty "startedCommands" for the request ID to avoid a memory leak.`
	`37`	`+ delete(startedCommands, evt.RequestID)`
`35`	`38`	`},`
`36`	`39`	`Failed: func(_ context.Context, evt *event.CommandFailedEvent) {`
`37`	`40`	`log.Printf("Command: %v Failure: %v\n",`
`38`	`41`	`startedCommands[evt.RequestID],`
`39`	`42`	`evt.Failure,`
`40`	`43`	`)`
	`44`	`+`
	`45`	`+ // Empty "startedCommands" for the request ID to avoid a memory leak.`
	`46`	`+ delete(startedCommands, evt.RequestID)`
`41`	`47`	`},`
`42`	`48`	`}`
`43`	`49`	`clientOpts := options.Client().ApplyURI("mongodb://localhost:27017").SetMonitor(cmdMonitor)`