Reactive Extensions 基于特定数量的并行处理

我是反应式扩展的新手。我有对象集合并为每个对象调用一个方法，并且方法返回布尔值。有没有办法通过使用 for every 循环并调用该方法来遍历每个反应性扩展对给定数量的对象（一次 5 个）同时调用（fork 和 join）方法，并且在第一个对象完成后，第 6 个对象应该调用方法，并且应该继续，直到所有对象都完成。

我很欣赏你的回复。

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);