c# - 在 C# 中对可观察对象进行分区

Question

我正在寻找某种方法将可观察序列拆分为单独的序列，我可以根据给定的谓词独立处理这些序列。像这样的东西是理想的:

var (evens, odds) = observable.Partition(x => x % 2 == 0);
var strings = evens.Select(x => x.ToString());
var floats = odds.Select(x => x / 2.0);

我能想到的最接近的方法是执行两个 where 过滤器，但这需要评估条件并处理源序列两次，对此我并不热衷。

observable = observable.Publish().RefCount();
var strings = observable.Where(x => x % 2 == 0).Select(x => x.ToString());
var floats = observable.Where(x => x % 2 != 0).Select(x => x / 2.0);

F# 似乎对此有很好的支持 Observable.partition<'T>和 Observable.split<'T,'U1,'U2> ，但我没能找到 C# 的任何等效项。

Answer 1

GroupBy 可能会移除“观察两次”限制，但您仍然会得到 Where 子句:

public static class X
{
    public static (IObservable<T> trues, IObservable<T> falsies) Partition<T>(this IObservable<T> source, Func<T, bool> partitioner)
    {
        var x = source.GroupBy(partitioner).Publish().RefCount();
        var trues = x.Where(g => g.Key == true).Merge();
        var falsies = x.Where(g => g.Key == false).Merge();
        return (trues, falsies);
    }
}