Издатель/подписчик в LINQ?

Question

Проблема:.

IEnumerable<Signal> feed = GetFeed(); 

var average1 = feed.MovingAverage(10); 
var average2 = feed.MovingAverage(20); 

var zipped = average1.Zip(average2, (x,y) => Tuple.Create(x,y)); 

Когда я перебирать "на молниях", GetFeed() GetEnumerator() вызывается дважды, и создает все виды проблем синхронизации. Существует ли оператор LINQ, который может использоваться для передачи значений от одного производителя нескольким потребителям? Я знаю о Memoize, но в моем случае я не могу предсказать размер буфера, чтобы медленные и быстрые потребители «счастливы».

Я думаю о написании собственного оператора, который будет хранить отдельные очереди для каждого потребителя, но хотел бы проверить, существует ли существующее решение.

Answer 1

Что вы хотите, это Reactive Extensions. Это похоже на LINQ to Objects, но наоборот: вы не тянете значения, они толкнул через наблюдателей.

Требуется некоторое время, чтобы привыкнуть к нему, но, судя по тому, что вы опубликовали, это точно подходящая модель для вас.