From ecbf42945e9708120feb8309caebd2618a8ea145 Mon Sep 17 00:00:00 2001
From: Oliver Eilhard <oliver@eilhard.net>
Date: Sat, 3 Jun 2017 13:32:26 +0200
Subject: [PATCH] Check for error in Reindexer

---
 reindexer.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/reindexer.go b/reindexer.go
index 7193a1337..fed5d513c 100644
--- 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()