diff --git a/src/ElasticquentCollectionTrait.php b/src/ElasticquentCollectionTrait.php
index c47906a..24feb34 100644
--- a/src/ElasticquentCollectionTrait.php
+++ b/src/ElasticquentCollectionTrait.php
@@ -34,7 +34,7 @@ public function addToIndex()
 
         // Iterate according to the amount configured, and put that iteration's worth of records into elastic search
         // This is done so that we do not exceed the maximum request size
-        $chunkingResult = $this->chunk(static::$entriesToSendToElasticSearchInOneGo, function ($collectionChunk) use ($result) {
+        $chunkingResult = $this->chunk(static::$entriesToSendToElasticSearchInOneGo)->each(function ($collectionChunk) use ($result) {
             $params = array();
             foreach ($collectionChunk as $item) {
                 $params['body'][] = array(