3
我有一個方法查詢:轉換IQueryable的實施IAsyncEnumerable
private readonly IEntityReader<Customer> _reader;
public async Task<IEnumerable<Customer>> HandleAsync(GetCustomer query)
{
var result = _reader.Query()
.Include(customer => customer.Organization)
.Where(customer => customer.Name == query.Name);
return await result.ToListAsync();
}
具有這種單元測試:
[Fact]
public async Task HandleGetCustomer_ReturnsCustomer_WhenNameMatches()
{
// Arrange
var customers = new List<Customer>()
{
new Customer
{
Id = new Guid("d4e749ba-6874-40f4-9134-6c9cc1bc95fe"),
Name = "John Doe",
Age = 18,
Organization = new Organization
{
Id = new Guid("b2ba06c9-5c00-4634-b6f7-80167ea8c3f1"),
Name = "TheCompany",
Number = 42
}
},
new Customer
{
Id = new Guid("0679ceb5-3d4f-41f3-a1b0-b167e1ac6d7e"),
Name = "Another Guy",
Age = 39,
Organization = new Organization
{
Id = new Guid("b2ba06c9-5c00-4634-b6f7-80167ea8c3f1"),
Name = "TheCompany",
Number = 42
}
}
}.AsQueryable();
var entityReader = new Mock<IEntityReader<Customer>>(MockBehavior.Strict);
entityReader.Setup(reader => reader.Query()).Returns(customers);
var query = new GetCustomer
{
Name = "John Doe"
};
var handler = new HandleGetCustomer(entityReader.Object);
// Act
var result = await handler.HandleAsync(query);
// Assert
Assert.NotNull(result);
Assert.True(result.Count() == 1);
Assert.True(result.FirstOrDefault().Id == new Guid("d4e749ba-6874-40f4-9134-6c9cc1bc95fe"));
}
通過apperently調用.ToListAsync();
失敗的原因爲:
源IQueryable未實現 IAsyncEnumerable。 僅實現IAsyncEnumerable的源可用於實體框架 的異步操作。
擴展方法是Entity Framework Core中的一種方法。
如何將我的客戶列表轉換爲IAsyncEnumerable
?
作爲參考,IEntityReader
接口被定義如:
public interface IEntityReader<out TEntity> where TEntity : Entity
{
IQueryable<TEntity> Query();
}
看看這裏http://stackoverflow.com/a/40500030/5233410解決方案可以修改並應用到您的使用案例 – Nkosi
看起來像那樣的代碼正在研究'DbSet',但我會看看。 –
janhartmann
是的,它也是IQueriable類型的。可以應用相同的策略。或者您可以查看ef源代碼內部使用的AsAsyncEnumerable擴展方法。 – Nkosi