Check for error in Reindexer

HomesNZ · Aug 7, 2017 · ecbf429 · ecbf429
1 parent c5744df
commit ecbf429
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/reindexer.go b/reindexer.go
@@ -192,6 +192,9 @@ func (ix *Reindexer) Do() (*ReindexerResponse, error) {
 		scanner = scanner.Size(ix.size)
 	}
 	cursor, err := scanner.Do()
+	if err != nil {
+		return nil, err
+	}
 
 	bulk := ix.targetClient.Bulk()