Làm thế nào để concat async enumerables?

Question

Tôi có một phương pháp với kiểu trả về này:

public async Task<IEnumerable<T>> GetAll() 

Nó làm cho một số cuộc gọi async thêm (số lượng không rõ) mỗi trong số đó trả về một nhiệm vụ T đếm được, và sau đó muốn concat các kết quả cho sự trở lại.

var data1 = src1.GetAll(); 
var data2 = src2.GetAll(); 
var data3 = src3.GetAll(); //and so on 

Bây giờ là đủ dễ dàng để chờ tất cả và concat kết quả để tạo ra đếm được duy nhất, nhưng tôi muốn các đếm được có sẵn ngay khi trở về cuộc gọi đầu tiên, với chờ đợi tiềm năng cho người gọi/Enumerator nếu bất kỳ cuộc gọi nào vẫn đang chờ xử lý khi kết quả có sẵn hết.

Tôi có phải cuộn tay một bản concat cho điều này, làm việc xung quanh việc thiếu sự hỗ trợ của điều tra viên khi nó được bao bọc trong một nhiệm vụ <>? Hoặc đã có một cuộc gọi thư viện trong TPL hoặc ở nơi khác có thể giúp tôi. Tôi đã nhìn vào IX, nhưng nó vẫn còn trên bản phát hành thử nghiệm và không muốn gấp nó lại.

Một lưu ý phụ, là những gì tôi đang cố gắng chống mẫu? Tôi có thể nghĩ về một biến chứng, xử lý ngoại lệ - từ phía người gọi, cuộc gọi có thể hoàn thành thành công và anh ta bắt đầu sử dụng số đếm nhưng nó có thể nổ tung vào giữa ...

Answer 1

Có một dự án hiện có tên là Async Enumerable vấn đề này chính xác.

Bạn có thể đặt nó để sử dụng khá dễ dàng.

Ví dụ:

IAsyncEnumerable<string> GetAsyncAnswers() 
{ 
    return AsyncEnum.Enumerate<string>(async consumer => 
    { 
     foreach (var question in GetQuestions()) 
     { 
      string theAnswer = await answeringService.GetAnswer(question); 
      await consumer.YieldAsync(theAnswer); 
     } 
    }); 
} 

này cho thấy một IAsyncEnumerable<string> trong đó sản lượng một lần GetAnswer lợi nhuận. Bạn có thể để lộ một số IAsyncEnumerable<T> trong trường hợp của bạn và thực hiện cuộc gọi trong nội bộ GetAll.

tôi đang cố gắng chống mẫu? Tôi có thể nghĩ đến một biến chứng, xử lý ngoại lệ - từ phía của người gọi, cuộc gọi có thể hoàn thành thành công và ông bắt đầu sử dụng đếm được nhưng nó có thể thổi lên giữa chừng qua đó ...

tôi sẽ không nói vậy. Điều này có các sự cố có khả năng xảy ra chẳng hạn như ngoại lệ xảy ra trong nội bộ trong một trong các trường hợp đang chờ xử lý, nhưng điều này cũng có thể có khả năng xảy ra bên trong bất kỳ IEnumerable<T> nào. Chuỗi không đồng bộ là thứ cần thiết trong thực tế ngày nay của API async mới nổi.