From 5c1073724b61d8b14e4614144310cf112fc2bac9 Mon Sep 17 00:00:00 2001
From: Fredy Freidenberger <drfredy@gmail.com>
Date: Sun, 18 Apr 2021 00:09:10 -0300
Subject: [PATCH] transaction parameter added to invocations of
 PaginateAsync<T> and PaginationResult<T>.Next methods within Chunk and
 ChunkAsync methods

---
 SqlKata.Execution/QueryFactory.cs | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/SqlKata.Execution/QueryFactory.cs b/SqlKata.Execution/QueryFactory.cs
index ce42dd40..49b08f75 100644
--- a/SqlKata.Execution/QueryFactory.cs
+++ b/SqlKata.Execution/QueryFactory.cs
@@ -527,7 +527,7 @@ public void Chunk<T>(
 
             while (result.HasNext)
             {
-                result = result.Next();
+                result = result.Next(transaction);
                 if (!func(result.List, result.Page))
                 {
                     return;
@@ -543,7 +543,7 @@ public async Task ChunkAsync<T>(
             int? timeout = null
         )
         {
-            var result = await this.PaginateAsync<T>(query, 1, chunkSize);
+            var result = await this.PaginateAsync<T>(query, 1, chunkSize, transaction);
 
             if (!func(result.List, 1))
             {
@@ -552,7 +552,7 @@ public async Task ChunkAsync<T>(
 
             while (result.HasNext)
             {
-                result = result.Next();
+                result = result.Next(transaction);
                 if (!func(result.List, result.Page))
                 {
                     return;
@@ -568,7 +568,7 @@ public void Chunk<T>(Query query, int chunkSize, Action<IEnumerable<T>, int> act
 
             while (result.HasNext)
             {
-                result = result.Next();
+                result = result.Next(transaction);
                 action(result.List, result.Page);
             }
         }
@@ -587,7 +587,7 @@ public async Task ChunkAsync<T>(
 
             while (result.HasNext)
             {
-                result = result.Next();
+                result = result.Next(transaction);
                 action(result.List, result.Page);
             }
         }