F#工作流生成器用于Rx

Question

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

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

我一直在尝试为工作流创建一个Using实现，但总是碰壁。也许这里已经太晚了。

如何创建这个Using实现？

type RxBuilder () =

    // ...

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

提前感谢。

- Bent Rasmussen

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())

- yamen

---

不错！我喜欢约束符号。看起来应该更仔细地研究fsharpx。 - Bent Rasmussen

我的 For 实现看起来像这样： member this.For(xs : 'a IObservable, f: 'a -> 'b IObservable) : 'b IObservable = xs.SelectMany(f)。但是还没有测试过。 - Bent Rasmussen

这基本上是一样的东西，只是出于样式原因（以匹配其他实现），我没有使用扩展方法格式，并且显式类型参数是为了确认一切按预期工作。 - yamen