c# - 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);
}