I have a class library written in C# that uses Reactive Extensions. I am trying to consume this library in a F# application.
I am calling a method on an object in my C# library that returns an IObservable. I have managed to use Observable.filter and Observable.subscribe to write out the data.
The main aim of the app is to read the data from the IObservable, write each received object to a file and then exit when complete.
How do I do the last part of this - how can I wait for the observable to complete (and it does - it is not an infinite stream) and then close the file and exit.
Microsoft is conducting an online survey to understand your opinion of the Msdn Web site. If you choose to participate, the online survey will be presented to you when you leave the Msdn Web site.
Would you like to participate?