Use Task<IEnumerable> instead of IAsyncEnumerable

Author: izzat5233

src/Controller/UserController.cs

@@ -50,7 +50,8 @@ public async Task FindAndDeleteProductAsync()
     public async Task DisplayProductsAsync()
     {
         var number = 1;
-        await foreach (var product in _repository.GetAllProductsAsync())
+        var products = await _repository.GetAllProductsAsync();
+        foreach (var product in products)
         {
             Console.WriteLine($"[{number++}] {product}");
         }

src/DAO/SqlProductDao.cs

@@ -1,4 +1,6 @@
+using System.Data;
 using System.Data.SqlClient;
+using Dapper;
 using SimpleInventoryManagementSystem.Domain;
 using SimpleInventoryManagementSystem.Interfaces;
 
@@ -15,14 +17,18 @@ public SqlProductDao(ISqlDataSource dataSource, ISqlProductMapper mapper)
         _mapper = mapper;
     }
 
-    public async IAsyncEnumerable<Product> GetAllProductsAsync()
+    public async Task<IEnumerable<Product>> GetAllProductsAsync()
     {
         const string sql = "SELECT * FROM Products";
         await using var reader = await _dataSource.ExecuteQueryAsync(sql, new List<SqlParameter>());
-        while (reader.Read())
+
+        var products = new List<Product>();
+        while (await reader.ReadAsync())
         {
-            yield return _mapper.MapToDomain(reader);
+            products.Add(_mapper.MapToDomain(reader));
         }
+
+        return products;
     }
 
     public async Task<Product?> GetProductByNameAsync(string productName)

src/Interfaces/IProductDao.cs

@@ -4,7 +4,7 @@ namespace SimpleInventoryManagementSystem.Interfaces;
 
 public interface IProductDao
 {
-    IAsyncEnumerable<Product> GetAllProductsAsync();
+    Task<IEnumerable<Product>> GetAllProductsAsync();
     Task<Product?> GetProductByNameAsync(string productName);
     Task DeleteProductByNameAsync(string productName);
     Task AddProductAsync(Product product);

src/Interfaces/IProductRepository.cs

@@ -4,7 +4,7 @@ namespace SimpleInventoryManagementSystem.Interfaces;
 
 public interface IProductRepository
 {
-    IAsyncEnumerable<Product> GetAllProductsAsync();
+    Task<IEnumerable<Product>> GetAllProductsAsync();
     Task<Product?> GetProductByNameAsync(string productName);
     Task DeleteProductByNameAsync(string productName);
     Task AddProductAsync(Product product);

src/Repository/ProductRepository.cs

@@ -8,8 +8,8 @@ public class ProductRepository : IProductRepository
     private readonly IProductDao _productDao;
     public ProductRepository(IProductDao productDao) => _productDao = productDao;
 
-    public IAsyncEnumerable<Product> GetAllProductsAsync() =>
-        _productDao.GetAllProductsAsync();
+    public async Task<IEnumerable<Product>> GetAllProductsAsync() =>
+        await _productDao.GetAllProductsAsync();
 
     public async Task<Product?> GetProductByNameAsync(string productName) =>
         await _productDao.GetProductByNameAsync(productName);