Skip to content

Commit d0b5afe

Browse files
committed
Added async tests
1 parent 4c79bb6 commit d0b5afe

4 files changed

Lines changed: 1622 additions & 5 deletions

File tree

CloudStub.AzureDataTables/TableClientStub.cs

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -244,14 +244,17 @@ public override async Task<NullableResponse<T>> GetEntityIfExistsAsync<T>(string
244244
}
245245

246246
public override Pageable<T> Query<T>(string filter = null, int? maxPerPage = null, IEnumerable<string> select = null, CancellationToken cancellationToken = default)
247-
{
248-
cancellationToken.ThrowIfCancellationRequested();
249-
return new PageableStub<T>(_GetEntityPageFactory<T>(FilterParser.Parse(FilterScanner.Scan(filter)), select, cancellationToken), maxPerPage);
250-
}
247+
=> new PageableStub<T>(_GetEntityPageFactory<T>(FilterParser.Parse(FilterScanner.Scan(filter)), select, cancellationToken), maxPerPage);
251248

252249
public override Pageable<T> Query<T>(Expression<Func<T, bool>> filter, int? maxPerPage = null, IEnumerable<string> select = null, CancellationToken cancellationToken = default)
253250
=> Query<T>(CreateQueryFilter(filter), maxPerPage, select, cancellationToken);
254251

252+
public override AsyncPageable<T> QueryAsync<T>(string filter = null, int? maxPerPage = null, IEnumerable<string> select = null, CancellationToken cancellationToken = default)
253+
=> new AsyncPageableStub<T>(_GetEntityPageFactory<T>(FilterParser.Parse(FilterScanner.Scan(filter)), select, cancellationToken), maxPerPage);
254+
255+
public override AsyncPageable<T> QueryAsync<T>(Expression<Func<T, bool>> filter, int? maxPerPage = null, IEnumerable<string> select = null, CancellationToken cancellationToken = default)
256+
=> QueryAsync<T>(CreateQueryFilter(filter), maxPerPage, select, cancellationToken);
257+
255258
public override Response<IReadOnlyList<TableSignedIdentifier>> GetAccessPolicies(CancellationToken cancellationToken = default)
256259
{
257260
cancellationToken.ThrowIfCancellationRequested();

0 commit comments

Comments
 (0)