Update EfRepository.cs

ardalis · Feb 18, 2021 · 68c23a7 · 68c23a7
1 parent 3460b82
commit 68c23a7
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/Clean.Architecture.Infrastructure/Data/EfRepository.cs b/src/Clean.Architecture.Infrastructure/Data/EfRepository.cs
@@ -38,6 +38,11 @@ public EfRepository(AppDbContext dbContext)
             var specificationResult = ApplySpecification(spec);
             return specificationResult.ToListAsync();
         }
+
+        public IAsyncEnumerable<T> GetAsyncEnumerable<T>() where T : BaseEntity, IAggregateRoot
+        {
+            return _dbContext.Set<T>().AsAsyncEnumerable<T>();
+        }
 
         public async Task<T> AddAsync<T>(T entity) where T : BaseEntity, IAggregateRoot
         {