反应式扩展 基于特定数量的并行处理

Question

我是反应式扩展的新手。我有对象集合并为每个对象调用一个方法，方法返回布尔值。而不是通过使用每个循环并调用方法来循环遍历每个循环，而是在反应式扩展中为给定数量的对象（一次 5 个）并发（分叉和连接）调用该方法，在第一个完成后，第 6 个应该调用方法，它应该继续直到所有对象都完成。

感谢您的回复。

Answer 1

IObservable<bool> someBoolAsyncMethod(SomeObject o)
someCollection.ToObservable()
    .Select(x => Observable.Defer(() => 
        someBoolAsyncMethod(x).Select(y => new { Item = x, Result = y})))
    .Merge(5)
    .ToList()
    .Subscribe(newListOfBools);