Skip to content

Commit 96e54f3

Browse files
Merge pull request #487 from muratkuru/master
Add CancellationToken Support To Async Methods
2 parents 799a9c3 + 25cce79 commit 96e54f3

File tree

3 files changed

+167
-142
lines changed

3 files changed

+167
-142
lines changed

SqlKata.Execution/PaginationResult.cs

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
using System;
22
using System.Collections.Generic;
33
using System.Data;
4+
using System.Threading;
45
using System.Threading.Tasks;
56

67
namespace SqlKata.Execution
@@ -71,9 +72,9 @@ public PaginationResult<T> Next(IDbTransaction transaction = null, int? timeout
7172
return this.Query.Paginate<T>(Page + 1, PerPage, transaction, timeout);
7273
}
7374

74-
public async Task<PaginationResult<T>> NextAsync(IDbTransaction transaction = null, int? timeout = null)
75+
public async Task<PaginationResult<T>> NextAsync(IDbTransaction transaction = null, int? timeout = null, CancellationToken cancellationToken = default)
7576
{
76-
return await this.Query.PaginateAsync<T>(Page + 1, PerPage, transaction, timeout);
77+
return await this.Query.PaginateAsync<T>(Page + 1, PerPage, transaction, timeout, cancellationToken);
7778
}
7879

7980
public Query PreviousQuery()
@@ -86,9 +87,9 @@ public PaginationResult<T> Previous(IDbTransaction transaction = null, int? time
8687
return this.Query.Paginate<T>(Page - 1, PerPage, transaction, timeout);
8788
}
8889

89-
public async Task<PaginationResult<T>> PreviousAsync(IDbTransaction transaction = null, int? timeout = null)
90+
public async Task<PaginationResult<T>> PreviousAsync(IDbTransaction transaction = null, int? timeout = null, CancellationToken cancellationToken = default)
9091
{
91-
return await this.Query.PaginateAsync<T>(Page - 1, PerPage, transaction, timeout);
92+
return await this.Query.PaginateAsync<T>(Page - 1, PerPage, transaction, timeout, cancellationToken);
9293
}
9394

9495
public PaginationIterator<T> Each

0 commit comments

Comments
 (0)