c# - System.Reactive.Joins 指南

Question

我正在寻找 System.Reactive.Joins 的介绍/一些文档，其中包括 Pattern、Plan、QueryablePattern 和 QueryablePlan 类。 Google 没有找到任何东西(“System.Reactive.Joins”)，MSDN 什么也没有，没有样本 here ，以及来自this question的优秀资源不要覆盖这个命名空间。

有没有人有一些指点？

Answer 1

找到了一个很好的 SO 问题，它显示了用法，但对我来说，计划和模式的总体目的是创建一个可观察的组合单元，而不是一个组合的可观察的。语义，我知道，但对我来说，使用这种语法似乎比使用其他各种“连接”方法更容易一些。它允许您将连接与投影完全分开，因此您可以存储中间计划并在需要时将它们与其他可观察对象组合。

例如:

// Suppose we have observables o1, o2, ..., o9. 
// All IObservable<int>.

var o1and2 = o1.And(o2);  // Store this bad boy for later use. Pattern<int, int>

var o5and6and9 = o5
                .And(o6)
                .And(o9)
                .Then((t1, t2, t3) => t1 + t2 + t3);  // Plan<int>

var o3and7 = o3
            .And(o7)
            .Then((t1, t2) => string.Format("Result: {0}", t1 + t2)); // Plan<string>

var o12ando8and6 = o1and2
                  .And(o8)
                  .And(o6)
                  .Then((t1, t2, t3, t4) => ((decimal) t1, t2, t3.ToString(), t4));   
                  // Plan<(decimal, int, string, int)>

// "When" groups similar results together.
// It will fire when any of the Patterns give a result.

var obs1 = Observable
          .When(o1and2.Then((t1,t2) => t1+t2), o5and6and9); // IObservable<int>

var obs2 = Observable.When(o3and7);       // IObservable<string>
var obs3 = Observable.When(o12ando8and6); // IObservable<(decimal, int, string,int)>

SO 文章: Reactive Extensions for .NET (Rx): Take action once all events are completed

此外，还找到了一份 RX 文档，它实际上有助于理解如何使用它:http://www.clipcode.net/mentoring/RxReferenceLibrary.pdf [死了]