< Summary

Class:Azure.Core.PageableHelpers
Assembly:Azure.Data.Tables
File(s):C:\Git\azure-sdk-for-net\sdk\core\Azure.Core\src\Shared\AutoRest\PageableHelpers.cs
Covered lines:32
Uncovered lines:0
Coverable lines:32
Total lines:85
Line coverage:100% (32 of 32)
Covered branches:19
Total branches:26
Branch coverage:73% (19 of 26)

Metrics

MethodCyclomatic complexity Line coverage Branch coverage
CreateEnumerable(...)-100%50%
CreateAsyncEnumerable(...)-100%50%
.ctor(...)-100%100%
AsPages()-100%75%
.ctor(...)-100%100%
AsPages()-100%83.33%

File(s)

C:\Git\azure-sdk-for-net\sdk\core\Azure.Core\src\Shared\AutoRest\PageableHelpers.cs

#LineLine coverage
 1// Copyright (c) Microsoft Corporation. All rights reserved.
 2// Licensed under the MIT License.
 3
 4#nullable enable
 5
 6using System;
 7using System.Collections.Generic;
 8using System.Threading.Tasks;
 9
 10namespace Azure.Core
 11{
 12    internal static class PageableHelpers
 13    {
 14        public static Pageable<T> CreateEnumerable<T>(Func<int?, Page<T>> firstPageFunc, Func<string?, int?, Page<T>>? n
 15        {
 70816            PageFunc<T> first = (continuationToken, pageSizeHint) => firstPageFunc(pageSizeHint);
 35417            PageFunc<T>? next = nextPageFunc != null ? new PageFunc<T>(nextPageFunc) : null;
 35418            return new FuncPageable<T>(first, next, pageSize);
 19        }
 20
 21        public static AsyncPageable<T> CreateAsyncEnumerable<T>(Func<int?, Task<Page<T>>> firstPageFunc, Func<string?, i
 22        {
 70823            AsyncPageFunc<T> first = (continuationToken, pageSizeHint) => firstPageFunc(pageSizeHint);
 35424            AsyncPageFunc<T>? next = nextPageFunc != null ? new AsyncPageFunc<T>(nextPageFunc) : null;
 35425            return new FuncAsyncPageable<T>(first, next, pageSize);
 26        }
 27
 28        internal delegate Task<Page<T>> AsyncPageFunc<T>(string? continuationToken = default, int? pageSizeHint = defaul
 29        internal delegate Page<T> PageFunc<T>(string? continuationToken = default, int? pageSizeHint = default);
 30
 31        internal class FuncAsyncPageable<T> : AsyncPageable<T> where T : notnull
 32        {
 33            private readonly AsyncPageFunc<T> _firstPageFunc;
 34            private readonly AsyncPageFunc<T>? _nextPageFunc;
 35            private readonly int? _defaultPageSize;
 36
 35437            public FuncAsyncPageable(AsyncPageFunc<T> firstPageFunc, AsyncPageFunc<T>? nextPageFunc, int? defaultPageSiz
 38            {
 35439                _firstPageFunc = firstPageFunc;
 35440                _nextPageFunc = nextPageFunc;
 35441                _defaultPageSize = defaultPageSize;
 35442            }
 43
 44            public override async IAsyncEnumerable<Page<T>> AsPages(string? continuationToken = default, int? pageSizeHi
 45            {
 35446                AsyncPageFunc<T>? pageFunc = _firstPageFunc;
 35447                int? pageSize = pageSizeHint ?? _defaultPageSize;
 48                do
 49                {
 39450                    Page<T> pageResponse = await pageFunc(continuationToken, pageSize).ConfigureAwait(false);
 39451                    yield return pageResponse;
 39452                    continuationToken = pageResponse.ContinuationToken;
 39453                    pageFunc = _nextPageFunc;
 78854                } while (!string.IsNullOrEmpty(continuationToken) && pageFunc != null);
 35455            }
 56        }
 57
 58        internal class FuncPageable<T> : Pageable<T> where T : notnull
 59        {
 60            private readonly PageFunc<T> _firstPageFunc;
 61            private readonly PageFunc<T>? _nextPageFunc;
 62            private readonly int? _defaultPageSize;
 63
 35464            public FuncPageable(PageFunc<T> firstPageFunc, PageFunc<T>? nextPageFunc, int? defaultPageSize = default)
 65            {
 35466                _firstPageFunc = firstPageFunc;
 35467                _nextPageFunc = nextPageFunc;
 35468                _defaultPageSize = defaultPageSize;
 35469            }
 70
 71            public override IEnumerable<Page<T>> AsPages(string? continuationToken = default, int? pageSizeHint = defaul
 72            {
 35473                PageFunc<T>? pageFunc = _firstPageFunc;
 35474                int? pageSize = pageSizeHint ?? _defaultPageSize;
 75                do
 76                {
 39477                    Page<T> pageResponse = pageFunc(continuationToken, pageSize);
 39478                    yield return pageResponse;
 39479                    continuationToken = pageResponse.ContinuationToken;
 39480                    pageFunc = _nextPageFunc;
 78881                } while (!string.IsNullOrEmpty(continuationToken) && pageFunc != null);
 35482            }
 83        }
 84    }
 85}