f# - 用于 Rx 的 F# 工作流构建器

Question

这里有一个很好的 Rx F# 工作流构建器：

http://blogs.msdn.com/b/dsyme/archive/2011/05/30/nice-f-syntax-for-rx-reactive-extensions.aspx

我一直在尝试为工作流做一个 Using 实现，但我一直在碰壁。也许在这里为时已晚。

一个人将如何创造这个？

type RxBuilder () =

    // ...

    member this.Using (disposable, f) =
        Observable.Using(???)

提前致谢。

Answer 1

首先，对于最新的 Rx 版本，原始代码需要稍微更新。即，For并且While应该实现为：

member this.For (xs : 'a seq, f: 'a -> 'b IObservable) =
    Observable.SelectMany(xs.ToObservable(), new Func<_, IObservable<_>>(f)) 

member this.While (f, xs: 'a IObservable) =
    Observable.TakeWhile (xs, new Func<_,bool>(fun _ -> f()))

然后，基于此，您可以使用以下实现Using：

member this.Using(res:#IDisposable, body) = this.TryFinally(body res, fun () -> match res with null -> () | disp -> disp.Dispose())