Publisher/Subscriber in LINQ?

Problem:

    IEnumerable<Signal> feed = GetFeed();

var average1 = feed.MovingAverage(10);
var a开发者_如何学Goverage2 = feed.MovingAverage(20);

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

When I iterate through "zipped", GetFeed().GetEnumerator() gets called twice and creates all sorts of synchronization issues. Is there a LINQ operator that can be used to broadcast values from single producer to multiple consumers? I know about Memoize, but in my case I can't predict buffer size to keep slow and fast consumers "happy".

I am thinking about writing my own operator that would keep separate queues for each consumer, but wanted to check if there is an existing solution.

What you want is Reactive Extensions. It's like LINQ to Objects, but in reverse: you don't pull values, they're pushed through observers.

It takes a little while to get used to it, but judging by what you've posted, it's exactly the right model for you.