0

我有一个我没有来源的第三方 API。我实例化一个回调到这样的事件：

using namespace API; // This is where APIClient lives

namespace TestApiClientUI
{
    public partial class Form1 : Form
    {
        APIClient apiClient = new APICLient();
        apiClient.QuoteUpdated += api_ClientUpdated;

        private void api_ClientUpdated(object sender, string s, double b, double a)
        {
        }
    }
}

如何将其包装到 Rx Observable.FromEvent 中？

另外，有没有办法让包装副本的开销尽可能少（零副本）？

4

1 回答 1

7

让我们定义一个结构来存储事件参数。

struct QuoteUpdate
{
    public string S { get; private set; }
    public double B { get; private set; }
    public double A { get; private set; }
    public QuoteUpdate(string s, double b, double a) : this()
    {
        S = s;
        B = b;
        A = a;
    }
}

现在我们可以定义IObservable<QuoteUpdate>如下。

var quoteUpdates = Observable.FromEvent<ApiQuoteHandler, QuoteUpdate>(
    emit => (_, s, b, a) => emit(new QuoteUpdate(s, b, a)),
    handler => apiClient.QuoteUpdated += handler,
    handler => apiClient.QuoteUpdated -= handler);

第一个 lambda 定义了从Action<QuoteUpdate>到的映射ApiQuoteHandler。被称为 的动作emit实际上是向我们定义的可观察对象的订阅者广播一个值。把 call 想象emit(value);成foreach (var subscriber in subscribers) { subscriber.OnNext(value); }.

我们需要第一个映射的原因是因为实际的底层事件只知道如何订阅和取消订阅ApiQuoteHandler实例。第二个和第三个 lambda 是 type Action<ApiQuoteHandler。它们分别在订阅和取消订阅时调用。

当IObserver<QuoteUpdate> observer订阅IObservable<QuoteUpdate>我​​们定义的时，会发生以下情况：

  1. observer.OnNext（类型Action<QuoteUpdate>）作为变量传递给我们的第一个 lambda emit。这将创建一个ApiQuoteHandler包装observer.
  2. 然后ApiQuoteHandler将作为变量传递给我们的第二个 lambda handler。handler订阅QuoteUpdated您的apiClient.
  3. 我们的方法IDisposable返回的 from包含对由我们的三个 lambda 中的第一个创建的的引用。SubscribeIObservable<QuoteUpdate>ApiQuoteHandler
  4. 当稍后IDisposable处理它时，第三个 lambda 会以与ApiQuoteHandler之前相同的方式调用，取消订阅基础事件。

因为你需要一个单一IObservable<T>的T但你有事件参数(s, b, a)，你必须定义一些结构或类来存储三个值。我不会担心复制string参考和两个double值的成本。

于 2015-08-11T21:12:30.353 回答