bUnit异步单元测试报错：IAsyncEnumerable实现缺失问题排查

问题根源 #

异常的核心原因是你Mock的DbSet<Student>仅实现了IQueryable<T>接口，但EF Core的异步查询方法（如ToListAsync、FirstOrDefaultAsync）要求数据源必须实现IAsyncEnumerable<T>接口——普通内存集合转成的IQueryable并不满足这个要求，因此触发了异常。

方案一：使用EF Core InMemory数据库（推荐） #

直接用EF Core官方提供的内存数据库模拟真实上下文行为，无需手动MockDbSet，更贴近真实业务场景：

// 配置InMemory数据库选项
var dbOptions = new DbContextOptionsBuilder<ApplicationDbContext>()
    .UseInMemoryDatabase("Test_Student_Db")
    .Options;

// 创建上下文并添加测试数据
using var context = new ApplicationDbContext(dbOptions);
context.Students.AddRange(
    new Student { Id = 1, Name = "张三" },
    new Student { Id = 2, Name = "李四" }
);
context.SaveChanges();

// 实例化真实的StudentsService并注入到bUnit服务容器
var studentService = new StudentsService(context);
Services.AddSingleton(studentService);

方案二：手动Mock DbSet实现IAsyncEnumerable #

如果坚持用Moq手动Mock，需要让DbSet同时实现IQueryable和IAsyncEnumerable接口：

1. 先定义异步枚举器辅助类：

public class TestAsyncEnumerator<T> : IAsyncEnumerator<T>
{
    private readonly IEnumerator<T> _innerEnumerator;

    public TestAsyncEnumerator(IEnumerator<T> enumerator)
    {
        _innerEnumerator = enumerator ?? throw new ArgumentNullException(nameof(enumerator));
    }

    public ValueTask DisposeAsync()
    {
        _innerEnumerator.Dispose();
        return ValueTask.CompletedTask;
    }

    public ValueTask<bool> MoveNextAsync()
    {
        return new ValueTask<bool>(_innerEnumerator.MoveNext());
    }

    public T Current => _innerEnumerator.Current;
}

2. 配置Mock的DbSet：

// 准备测试数据
var testStudents = new List<Student>
{
    new Student { Id = 1, Name = "张三" },
    new Student { Id = 2, Name = "李四" }
}.AsQueryable();

// Mock DbSet
var mockDbSet = new Mock<DbSet<Student>>();

// 实现IQueryable接口
mockDbSet.As<IQueryable<Student>>().Setup(m => m.Provider).Returns(testStudents.Provider);
mockDbSet.As<IQueryable<Student>>().Setup(m => m.Expression).Returns(testStudents.Expression);
mockDbSet.As<IQueryable<Student>>().Setup(m => m.ElementType).Returns(testStudents.ElementType);
mockDbSet.As<IQueryable<Student>>().Setup(m => m.GetEnumerator()).Returns(testStudents.GetEnumerator());

// 关键：实现IAsyncEnumerable接口
mockDbSet.As<IAsyncEnumerable<Student>>()
    .Setup(m => m.GetAsyncEnumerator(It.IsAny<CancellationToken>()))
    .Returns(new TestAsyncEnumerator<Student>(testStudents.GetEnumerator()));

// Mock上下文的Students属性
var mockContext = new Mock<ApplicationDbContext>();
mockContext.Setup(c => c.Students).Returns(mockDbSet.Object);

// 注入服务
var studentService = new StudentsService(mockContext.Object);
Services.AddSingleton(studentService);

内容的提问来源于stack exchange，提问作者Ervis Trupja