c# - 我怎样才能从 IObservable 获取历史记录？

Question

我正在通过 Observable 监控股票报价流，我观察它以匹配特定条件，例如 -

Observable
.Empty<Quote>
.Where(q => q.Price > watchPrice)
.Subscribe(q => { // do stuff } );

现在，在“做事”这一点上，我最理想的做法是获取 where 子句中出现的最后 3 个“q”，有点像 BufferWithCount()，但是订阅的每个条目() 包含最后 3 个条目。这样我就可以保存导致条件评估的报价更改的快照。

伪大理石图 -

in  -  a     b     c     d     e     f
out -  a     ba    cba   dcb   edc   fde

任何想法表示赞赏

Answer 1

像这样？

    static void Main()
    {
        new[] {"a", "b", "c", "d", "e", "f"}
            .ToObservable()
            .Scan(Enumerable.Empty<string>(), (x, y) => x.StartWith(y).Take(3))
            .Subscribe(x =>
                           {
                               x.Run(Console.Write);
                               Console.WriteLine();
                           });
        Console.ReadLine();
    }