iobservable

Using reactive extensions to hold onto the most recent event in a series of events until x seconds after most recent event has been received.

I am trying to understand how the following scenario could be implemented using reactive extensions. Other solutions that I have been looking at involve managing a series of timers... something that I am looking to avoid if possible. Scenario A stream of "ActionRequests" occurring. The ActionRequest's streaming in are from different o...

IObservable in Silverlight 4

Where can I find this class? I have included the Rx extensions. I have made sure the version I'm compiling to is Silverlight 4. My VS2010 IDE still has no idea what the type IObservable is. I didn't see them in the System.Collections.Generic namespace like this thread suggests http://dotnet.uservoice.com/forums/4325-silverlight-feature-...

MethodCallExpression with IObservable throws access denied exception to System.CoreEx

I have a MethodCallExpression object from which I'm trying to return a IObservable<Thing> instance using the Reactive Extensions framework. private IObservable<Thing> GetThing(Expression<Func<Thing>> expression) { Func<Thing> method = expression.Compile() var observable = Observable.FromAsyncPattern<Thing>(method.BeginInvoke, meth...

Make the PhoneApplicationService.Current.State Dictionary Observable?

Hi, In a Windows Phone 7 app, the PhoneApplicationService.Current.State object is declared as an IDictionary, and is implemented as a Dictionary. I was really hoping to get notified when any state changes occur. (I realise I could build my own state collection somewhere else and do whatever I want, but I'm retrofitting this into existin...

Observable.Delay calling Dispose before OnNext is fired

I am having problem understanding how Observable.Delay works and when the Dispose() is meant to be called. Would anyone familiar with Rx be able to help please? The following code snippet: static void Main(string[] args) { var oneNumberEveryFiveSeconds = new SomeObservable(); // Instant echo oneNumberEve...

Should I use List<IObserver> or simply Action<T> to keep track of an IObservable's subscribers?

I'm implementing the IObservable<T> interface on some classes. I used Reflector to figure out how this is typically done in Rx. Concerning how an observable keeps track of its subscribers and notifies them via their OnNext method, I stumbled upon code similar to this: private List<Observer<T>> observers; // subscribe a new observer: pu...