#27

ManagedCode.Repository.AzureTable/BaseAzureTableRepository.cs

@@ -245,6 +245,16 @@ protected override async Task<TItem> GetAsyncInternal(Expression<Func<TItem, boo
             var item = await _tableAdapter.Query<TItem>(predicate, take: 1, cancellationToken: token).ToListAsync(token);
             return item.FirstOrDefault();
         }
+
+        protected override IAsyncEnumerable<TItem> GetAllAsyncInternal(int? take = null, int skip = 0, CancellationToken token = default)
+        {
+            return _tableAdapter.Query<TItem>(null, take: take, skip: skip, cancellationToken: token);
+        }
+
+        protected override IAsyncEnumerable<TItem> GetAllAsyncInternal(Expression<Func<TItem, object>> orderBy, Order orderType, int? take = null, int skip = 0, CancellationToken token = default)
+        {
+            return _tableAdapter.Query(null, orderBy, orderType, take: take, skip: skip, cancellationToken: token);
+        }
 
         #endregion
 

ManagedCode.Repository.AzureTable/ManagedCode.Repository.AzureTable.csproj

@@ -8,7 +8,7 @@
         <Authors>ManagedCode</Authors>
         <PackageLicenseUrl>https://github.com/managed-code-hub/Repository/blob/main/LICENSE</PackageLicenseUrl>
         <RepositoryUrl>https://github.com/managed-code-hub/Repository</RepositoryUrl>
-        <PackageVersion>1.0.3</PackageVersion>
+        <PackageVersion>1.0.4</PackageVersion>
         <Description>Repository for AzureTable</Description>
     </PropertyGroup>
 

ManagedCode.Repository.Core/BaseRepository.cs

@@ -162,9 +162,35 @@ public Task<TItem> GetAsync(Expression<Func<TItem, bool>> predicate, Cancellatio
             return GetAsyncInternal(predicate, token);
         }
 
+        public IAsyncEnumerable<TItem> GetAllAsync(int? take = null, int skip = 0, CancellationToken token = default)
+        {
+            return GetAllAsyncInternal(take, skip, token);
+        }
+
+        public IAsyncEnumerable<TItem> GetAllAsync(Expression<Func<TItem, object>> orderBy, int? take = null, int skip = 0, CancellationToken token = default)
+        {
+            return GetAllAsyncInternal(orderBy, Order.By, take, skip, token);
+        }
+
+        public IAsyncEnumerable<TItem> GetAllAsync(Expression<Func<TItem, object>> orderBy, Order orderType,
+            int? take = null,
+            int skip = 0,
+            CancellationToken token = default)
+        {
+            return GetAllAsyncInternal(orderBy, orderType, take, skip, token);
+        }
+
         protected abstract Task<TItem> GetAsyncInternal(TId id, CancellationToken token = default);
         protected abstract Task<TItem> GetAsyncInternal(Expression<Func<TItem, bool>> predicate, CancellationToken token = default);
 
+        protected abstract IAsyncEnumerable<TItem> GetAllAsyncInternal(int? take = null, int skip = 0, CancellationToken token = default);
+
+        protected abstract IAsyncEnumerable<TItem> GetAllAsyncInternal(Expression<Func<TItem, object>> orderBy,
+            Order orderType,
+            int? take = null,
+            int skip = 0,
+            CancellationToken token = default);
+
         #endregion
 
         #region Find

ManagedCode.Repository.Core/IRepository.cs

@@ -30,6 +30,22 @@ public interface IRepository<in TId, TItem> where TItem : IItem<TId>
 
         Task<TItem> GetAsync(TId id, CancellationToken token = default);
         Task<TItem> GetAsync(Expression<Func<TItem, bool>> predicate, CancellationToken token = default);
+
+        IAsyncEnumerable<TItem> GetAllAsync(
+            int? take = null,
+            int skip = 0,
+            CancellationToken token = default);
+
+        IAsyncEnumerable<TItem> GetAllAsync(Expression<Func<TItem, object>> orderBy,
+            int? take = null,
+            int skip = 0,
+            CancellationToken token = default);
+
+        IAsyncEnumerable<TItem> GetAllAsync(Expression<Func<TItem, object>> orderBy,
+            Order orderType,
+            int? take = null,
+            int skip = 0,
+            CancellationToken token = default);
 
         IAsyncEnumerable<TItem> FindAsync(Expression<Func<TItem, bool>> predicate, int? take = null, int skip = 0, CancellationToken token = default);
 

ManagedCode.Repository.Core/InMemoryRepository.cs

@@ -229,6 +229,55 @@ protected override Task<TItem> GetAsyncInternal(Expression<Func<TItem, bool>> pr
             }
         }
 
+        protected override async IAsyncEnumerable<TItem> GetAllAsyncInternal(int? take = null, int skip = 0, CancellationToken token = default)
+        {
+            await Task.Yield();
+            lock (_storage)
+            {
+                var enumerable = _storage.Values.Skip(skip);
+
+                if (take.HasValue)
+                {
+                    enumerable = enumerable.Take(take.Value);
+                }
+
+                foreach (var item in enumerable)
+                {
+                    yield return item;
+                }
+            }
+        }
+
+        protected override async IAsyncEnumerable<TItem> GetAllAsyncInternal(Expression<Func<TItem, object>> orderBy, Order orderType, int? take = null, int skip = 0, CancellationToken token = default)
+        {
+            await Task.Yield();
+            lock (_storage)
+            {
+
+                IEnumerable<TItem> enumerable;
+                if (orderType == Order.By)
+                {
+                    enumerable = _storage.Values.OrderBy(orderBy.Compile());
+                }
+                else
+                {
+                    enumerable = _storage.Values.OrderByDescending(orderBy.Compile());
+                }
+
+                enumerable = enumerable.Skip(0);
+
+                if (take.HasValue)
+                {
+                    enumerable = enumerable.Take(take.Value);
+                }
+
+                foreach (var item in enumerable)
+                {
+                    yield return item;
+                }
+            }
+        }
+
         #endregion
 
         #region Find

ManagedCode.Repository.Core/ManagedCode.Repository.Core.csproj

@@ -9,7 +9,7 @@
         <PackageProjectUrl>https://github.com/managed-code-hub/Repository</PackageProjectUrl>
         <PackageLicenseUrl>https://github.com/managed-code-hub/Repository/blob/main/LICENSE</PackageLicenseUrl>
         <RepositoryUrl>https://github.com/managed-code-hub/Repository</RepositoryUrl>
-        <PackageVersion>1.0.3</PackageVersion>
+        <PackageVersion>1.0.4</PackageVersion>
         <Description>Base implementation for Repository</Description>
     </PropertyGroup>
 

ManagedCode.Repository.CosmosDB/CosmosDbRepository.cs

@@ -451,6 +451,75 @@ protected override async Task<TItem> GetAsyncInternal(Expression<Func<TItem, boo
 
             return null;
         }
+
+        protected override async IAsyncEnumerable<TItem> GetAllAsyncInternal(int? take = null, int skip = 0, [EnumeratorCancellation] CancellationToken token = default)
+        {
+            var container = await _cosmosDbAdapter.GetContainer();
+            var query = container.GetItemLinqQueryable<TItem>().Where(SplitByType());
+
+            if (skip > 0)
+            {
+                query = query.Skip(skip);
+            }
+
+            if (take.HasValue)
+            {
+                query = query.Take(take.Value);
+            }
+
+            var feedIterator = query.ToFeedIterator();
+            using (var iterator = feedIterator)
+            {
+                while (iterator.HasMoreResults)
+                {
+                    token.ThrowIfCancellationRequested();
+
+                    foreach (var item in await iterator.ReadNextAsync(token))
+                    {
+                        yield return item;
+                    }
+                }
+            }
+        }
+
+        protected override async IAsyncEnumerable<TItem> GetAllAsyncInternal(Expression<Func<TItem, object>> orderBy, Order orderType, int? take = null, int skip = 0, [EnumeratorCancellation] CancellationToken token = default)
+        {
+            var container = await _cosmosDbAdapter.GetContainer();
+            var query = container.GetItemLinqQueryable<TItem>().Where(SplitByType());
+
+            if (orderType == Order.By)
+            {
+                query = query.OrderBy(orderBy);
+            }
+            else
+            {
+                query = query.OrderByDescending(orderBy);
+            }
+
+            if (skip > 0)
+            {
+                query = query.Skip(skip);
+            }
+
+            if (take.HasValue)
+            {
+                query = query.Take(take.Value);
+            }
+
+            var feedIterator = query.ToFeedIterator();
+            using (var iterator = feedIterator)
+            {
+                while (iterator.HasMoreResults)
+                {
+                    token.ThrowIfCancellationRequested();
+
+                    foreach (var item in await iterator.ReadNextAsync(token))
+                    {
+                        yield return item;
+                    }
+                }
+            }
+        }
 
         #endregion
 

ManagedCode.Repository.CosmosDB/ManagedCode.Repository.CosmosDB.csproj

@@ -8,7 +8,7 @@
         <Authors>ManagedCode</Authors>
         <PackageLicenseUrl>https://github.com/managed-code-hub/Repository/blob/main/LICENSE</PackageLicenseUrl>
         <RepositoryUrl>https://github.com/managed-code-hub/Repository</RepositoryUrl>
-        <PackageVersion>1.0.3</PackageVersion>
+        <PackageVersion>1.0.4</PackageVersion>
         <Description>Repository for CosmosDB</Description>
     </PropertyGroup>
 

ManagedCode.Repository.LiteDB/LiteDbRepository.cs

@@ -176,6 +176,61 @@ protected override async Task<TItem> GetAsyncInternal(Expression<Func<TItem, boo
             await Task.Yield();
             return GetDatabase().FindOne(predicate);
         }
+
+        protected override async IAsyncEnumerable<TItem> GetAllAsyncInternal(int? take = null, int skip = 0, CancellationToken token = default)
+        {
+            await Task.Yield();
+            var query = GetDatabase().Query().Skip(skip).Limit(take ?? 2147483647);
+            foreach (var item in query.ToEnumerable())
+            {
+                if (token.IsCancellationRequested)
+                {
+                    break;
+                }
+
+                yield return item;
+            }
+        }
+
+        protected override async IAsyncEnumerable<TItem> GetAllAsyncInternal(Expression<Func<TItem, object>> orderBy, Order orderType, int? take = null, int skip = 0, CancellationToken token = default)
+        {
+            await Task.Yield();
+            var query = GetDatabase().Query();
+
+            if (orderType == Order.By)
+            {
+                query = query.OrderBy(orderBy);
+            }
+            else
+            {
+                query.OrderByDescending(orderBy);
+            }
+
+            if (take != null)
+            {
+                foreach (var item in query.Limit(take.Value).ToEnumerable())
+                {
+                    if (token.IsCancellationRequested)
+                    {
+                        break;
+                    }
+
+                    yield return item;
+                }
+            }
+            else
+            {
+                foreach (var item in query.ToEnumerable())
+                {
+                    if (token.IsCancellationRequested)
+                    {
+                        break;
+                    }
+
+                    yield return item;
+                }
+            }
+        }
 
         #endregion
 

ManagedCode.Repository.LiteDB/ManagedCode.Repository.LiteDB.csproj

@@ -8,7 +8,7 @@
         <Authors>ManagedCode</Authors>
         <PackageLicenseUrl>https://github.com/managed-code-hub/Repository/blob/main/LICENSE</PackageLicenseUrl>
         <RepositoryUrl>https://github.com/managed-code-hub/Repository</RepositoryUrl>
-        <PackageVersion>1.0.3</PackageVersion>
+        <PackageVersion>1.0.4</PackageVersion>
         <Description>Repository for LiteDB</Description>
     </PropertyGroup>
 
@@ -19,7 +19,7 @@
     <ItemGroup>
       <PackageReference Include="LiteDB" Version="5.0.10" />
       <PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="5.0.0" />
-      <PackageReference Include="Newtonsoft.Json" Version="10.0.2" />
+      <PackageReference Include="Newtonsoft.Json" Version="12.0.3" />
     </ItemGroup>
 
 </Project>

ManagedCode.Repository.Tests/ManagedCode.Repository.Tests.csproj

@@ -9,14 +9,14 @@
 
     <ItemGroup>
         <PackageReference Include="FluentAssertions" Version="5.10.3" />
-        <PackageReference Include="Microsoft.NET.Test.Sdk" Version="16.7.1" />
+        <PackageReference Include="Microsoft.NET.Test.Sdk" Version="16.9.1" />
         <PackageReference Include="System.Linq.Async" Version="5.0.0" />
         <PackageReference Include="xunit" Version="2.4.1" />
         <PackageReference Include="xunit.runner.visualstudio" Version="2.4.3">
             <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
             <PrivateAssets>all</PrivateAssets>
         </PackageReference>
-        <PackageReference Include="coverlet.collector" Version="1.3.0">
+        <PackageReference Include="coverlet.collector" Version="3.0.3">
             <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
             <PrivateAssets>all</PrivateAssets>
         </PackageReference>