check if cursor was closed while fetching results

dancannon · dancannon · commit 1bb9e3a19a7c · 2016-01-30T15:40:57.000Z
diff --git a/cursor.go b/cursor.go
@@ -196,6 +196,10 @@ func (c *Cursor) loadNextLocked(dest interface{}) (bool, error) {
 			if err != nil {
 				return false, err
 			}
+			// Check if cursor was closed while fetching results
+			if c.closed {
+				return false, nil
+			}
 		}
 
 		if len(c.buffer) == 0 && len(c.responses) == 0 && c.finished {

Original file line number	Diff line number	Diff line change
`@@ -196,6 +196,10 @@ func (c *Cursor) loadNextLocked(dest interface{}) (bool, error) {`
`196`	`196`	`if err != nil {`
`197`	`197`	`return false, err`
`198`	`198`	`}`
	`199`	`+ // Check if cursor was closed while fetching results`
	`200`	`+ if c.closed {`
	`201`	`+ return false, nil`
	`202`	`+ }`
`199`	`203`	`}`
`200`	`204`
`201`	`205`	`if len(c.buffer) == 0 && len(c.responses) == 0 && c.finished {`