Merge pull request quickfixgo#344 from michaelwilner/iter-close

cbusbey · web-flow · commit a3f542115a2c · 2018-10-31T13:34:00.000-05:00
Close iterator when getting messages
diff --git a/mongostore.go b/mongostore.go
@@ -244,6 +244,7 @@ func (store *mongoStore) GetMessages(beginSeqNum, endSeqNum int) (msgs [][]byte,
 	for iter.Next(msgFilter) {
 		msgs = append(msgs, msgFilter.Message)
 	}
+	err = iter.Close()
 	return
 }
 

Original file line number	Diff line number	Diff line change
`@@ -244,6 +244,7 @@ func (store *mongoStore) GetMessages(beginSeqNum, endSeqNum int) (msgs [][]byte,`
`244`	`244`	`for iter.Next(msgFilter) {`
`245`	`245`	`msgs = append(msgs, msgFilter.Message)`
`246`	`246`	`}`
	`247`	`+ err = iter.Close()`
`247`	`248`	`return`
`248`	`249`	`}`
`249`	`250`