题
有没有办法从 F# 中的序列创建可观察对象?
所需的行为是订阅结果可观察值的观察者一次接收序列的所有值。
编辑: :这个问题可以表述为:有没有相当于 Rx.Observable.FromArray([1,2,3])
如图所示 这里 在 F# 中?
编辑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 ()
解决方案
是 System.Reactive.Linq.Observable.ToObservable(此 IEnumerable 源) 位于 系统响应.dll 你想要的东西?
其他提示
以防万一您想避免额外的依赖关系,实际上使用 F# 事件和实现该行为非常容易 Observable.guard
我已经使用过的函数 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 }
您可以尝试反应式扩展。请参考以下博客文章,它可能对您有很大帮助。
http://www.navision-blog.de/2009/10/20/iobservableiobserver-using-the-reactive-framework-with-f/
不隶属于 StackOverflow