'RX.NET batched timer processing by key - how to project List<T> instead of T? [duplicate]

Let's say you have a stream of stock updates StockUpdate:

public class StockUpdate
{
  public string Symbol { get; set; }
  public string Price { get; set; }
}

Every n seconds, you want to emit a List that contains the last value for each of the symbols.

How can I do this with RX.NET? Similar questions on StackOverflow leverage GroupBy/SelectMany with sample, but this would project each item, not a list. I could buffer that list again, but then that would create extra delay.

c++sharprx.net


Solution 1:[1]

maybe you can try this.. by replacing the Observable.Empty<> by your source object...

a sorry you want a list of as result..

        IObservable<IEnumerable<StockUpdate>> y = Observable.Empty<StockUpdate>()
            .Buffer(TimeSpan.FromSeconds(1))
            .Select(b => 
                    b
                    .GroupBy(su=> su.Symbol)
                    .Select(grp=> new StockUpdate { Symbol = grp.Key, Price = grp.Last().Price }))
            ;

Solution 2:[2]

Are you looking for something like this:

IObservable<StockUpdate> source = ...;

IObservable<IList<StockUpdate>> query =
    source
        .Window(TimeSpan.FromSeconds(1.0))
        .Select(xs => xs.ToList())
        .Merge();

Sources

This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.

Source: Stack Overflow

Solution Source
Solution 1
Solution 2 Enigmativity

Related Questions