Rx.NET - 一次下载两个文件

Question

我试图下载一个文件列表（使用被动扩展），一次保持最多两个并行下载。

到目前为止，我没有遇到过工作示例。

最接近的事至今是：

How can I limit Parallel.ForEach?

但我想这样做是通过Rx.net 任何帮助将非常感激。

Answer 1

Observable.Merge需要一个maxConcurrent参数，它允许您限制维护多少个并行订阅。所以你可以这样做：

public class DownloadResult { /*...*/ } 

public Task<DownloadResult> DownloadFileAsync(string path) { /*...*/ } 


public IObservable<DownloadResult> DownloadFiles(int maxConcurrent, string[] paths) 
{ 
    return paths 
     .Select(path => Observable.FromAsync(() => DownloadFileAsync(path))) 
     .Merge(maxConcurrent: maxConcurrent); 
}