我应该使用List＆LT; IObserver＆GT;或者干脆动作＆LT; T＆GT;跟踪一个的IObservable的订户的？ [英] Should I use List<IObserver> or simply Action<T> to keep track of an IObservable's subscribers?

问题描述

我实施的IObservable＆LT; T＆gt;在一些班级接口。我用反射弄清楚如何，这是通常的接收。关于如何可观察到的保持其用户的轨迹，并通过他们的 OnNext 方法通知他们，我偶然发现了与此类似code：

I'm implementing the IObservable<T> interface on some classes. I used Reflector to figure out how this is typically done in Rx. Concerning how an observable keeps track of its subscribers and notifies them via their OnNext method, I stumbled upon code similar to this:

private List<Observer<T>> observers;

// subscribe a new observer:
public IDisposable Subscribe(IObserver<T> observer)
{
    observers.Add(observer);
    ...
}

// trigger all observers' OnNext method:
...
foreach (IObserver<T> observer in observers)
{
    observer.OnNext(value);
}

由于所有代表都是多投，不能这样被简化为：

Since all delegates are multi-cast, couldn't this be simplified to:

Action<T> observers;

// subscribe observer:
public IDisposable Subscribe(IObserver<T> observer)
{
    observers += observer.OnNext;
    ...
}

// trigger observers' OnNext:
...
observers(value);

---

还是有特定的优势，以第一种方法（性能，线程/并发问题，＆hellip;）？

---

Or are there specific advantages to the first approach (performance, threading/concurrency issues, …)?

推荐答案

在一般情况下，单独要求代表们提供了更多的控制权的行为：

In general, calling the delegates individually gives you more control over the behavior:

• 如果一名代表提出了一个异常，你可以保持通话的人，例如，或从列表中移除故障委托。
• 如果你想调用并行的代表，它真的很容易。
• 如果您需要调用它们按照一定的顺序，你可以很容易地保证按正确的顺序（我不知道该多播委托的调用顺序被定义）。

这篇关于我应该使用List＆LT; IObserver＆GT;或者干脆动作＆LT; T＆GT;跟踪一个的IObservable的订户的？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！