0

给定具有 IObservable 子属性的对象的 IObservable，我如何去过滤主要的 observable 以仅包含子属性具有至少 X 个项目的实例。

例如下面的测试用例有一个包含 2 个 MyClass 的 IObservable。第一个包含 5 个整数的可观察值，第二个包含 2 个整数。所以我的问题是如何过滤 MyClass 的 IObservable 以仅包含包含 4 个或更多数字的实例？

[TestClass]
public class TestClass
{
    public class MyClass
    {
        public IObservable<int> Numbers { get; set; }
    }

    [TestMethod]
    public void Test()
    {
        //Arrange       
        var data = new []
        {
            new MyClass()
            {
                Numbers = new Observable.Range(100, 5)
            },
            new MyClass()
            {
                Numbers = new Observable.Range(200, 2)
            }
        };

        var observableData = data.ToObservable();

        //Act
        //TODO: set filtered so that it includes
        // all instances of MyClass which have 4
        // or more items in Numbers
        IObservable<List<MyClass>> filtered = observableData

        //Assert
        IObservable<List<MyClass>> observableResult = 
            filtered.Aggregate(new List<MyClass>(), 
                (l, o) => 
                    { 
                        l.Add(o); 
                            return l; 
                    });

        var result = observableResult.Wait();
        //expected result should include data[0] because
        // is contains 5 numbers but exclude data[1] 
        // because it only contains 2.
        var expected = new List<MyClass>() { data[0] };

        CollectionAssert.AreEquivalent(expected, result);
    }
}

任何帮助表示赞赏。

4

1 回答 1

0

解决方案：

IObservable<MyClass> filtered = observableData
    .SelectMany(c => c.Numbers
        .Skip(3)
        .Take(1)
        .Select(_ => c)
    );

用英语：对于 的每个实例MyClass，产生一个跳过前 3 个数字的 observable，然后取一个。将该数字映射到 的原始实例MyClass。我们使用SelectMany将生成的 observables 扁平化为一个。

于 2017-03-20T14:53:00.473 回答