F# .NET 4.0 IObservable Reactive Extensions


  • Hi all,

    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.


    • Edited by Alan Rutter Friday, March 07, 2014 1:32 AM edit
    Thursday, March 06, 2014 11:36 PM