F＃中序列的可觀察數

Question

有沒有辦法從F＃中的序列創建觀察值？

需要的行爲是訂閱生成的observable的觀察者一次接收一個序列的所有值。

編輯：該問題可以被構造爲：是否存在一個等效於Rx.Observable.FromArray([1,2,3])，如F＃中的here？

編輯2：謝謝大家。我花了一些時間才找到答案，只是發現desco已經回答了。爲了完整起見，這裏是它是如何工作的：

//Using the Reactive Framework. 
//References to System.CoreEx.dll and System.Reactive.dll are needed. 

open System.Linq 

let observable = Observable.ToObservable [1..10] 
let odds = observable |> Observable.filter (fun i -> i%2=1) 
let disp = odds.Subscribe (fun i -> printfn "%d" i) 
disp.Dispose() 

Answer 1

是System.Reactive.Linq.Observable.ToObservable(this IEnumerable source)位於System.Reactive.dll的事情你一點呢？

Answer 2

你可以嘗試反應性擴展。請參閱以下博客條目，這可能會對您有所幫助。

http://www.navision-blog.de/2009/10/20/iobservableiobserver-using-the-reactive-framework-with-f/

Answer 3

爲防萬一你想避免額外的依賴，實際上很容易實現使用F＃事件和我已經在another answer here at StackOverflow中使用的Observable.guard函數。

下面是實現連同一個簡單的例子：

module Observable = 
    let ofSeq s = 
    let evt = new Event<_>() 
    evt.Publish |> Observable.guard (fun o -> 
     for n in s do evt.Trigger(n)) 

[ 1 .. 10 ] |> Observable.ofSeq 
      |> Observable.filter (fun n -> n%2 = 0) 
      |> Observable.add (printfn "%d") 

而對於完整性，Observable.guard實施看起來是這樣的：

/// Creates an observable that calls the specified function after someone 
/// subscribes to it (useful for waiting using 'let!' when we need to start 
/// operation after 'let!' attaches handler) 
let guard f (e:IObservable<'Args>) = 
    { new IObservable<'Args> with 
     member x.Subscribe(observer) = 
     let rm = e.Subscribe(observer) in f(); rm }