Наблюдаемый из последовательности в F #

Question

Есть ли способ создать наблюдаемый из последовательности в F #?

Требуемое поведение заключается в том, что наблюдатель, подписавшийся на итоговый наблюдаемый, получает все значения последовательности по одному за раз.

Edit: Вопрос может быть оформлена как: Есть ли эквивалент Rx.Observable.FromArray([1,2,3]), как показано here в F #?

Редактировать 2: Спасибо всем. Мне потребовалось некоторое время, чтобы найти ответ, только чтобы найти, что деско уже ответила. Для полноты, вот как это работает:

//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

Yoou может попробовать реактивные расширения. Пожалуйста, обратитесь к следующей записи в блоге, которая может вам помочь.

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

Answer 3

На всякий случай вы хотели избежать дополнительной зависимости, на самом деле довольно просто реализовать поведение с использованием событий F # и функции Observable.guard, которую я уже использовал в another answer here at StackOverflow.

Вот реализация вместе с кратким примером:

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 }