c# - 反应式扩展：每种类型只允许一个订阅者

Question

有没有办法确保每个类型最多可以注册一个泛型类型的订阅者？一个例子可以更好地解释它：

public interface Message
{

}

public class Command : Message
{

}

public class Event : Message
{

}

public class Bus
{
    private readonly IObservable<Message> _stream;
    private readonly Subject<Message> _subject;

    public Bus()
    {
        _subject = new Subject<Message>();
        _stream = _subject.AsObservable();
    }

    public IDisposable Subscribe<T>(IObserver<T> observer) where T:Command
    {
        return _stream.OfType<T>().Subscribe(observer);
    }

    public void Execute<T>(T command) where T:Command
    {
        _subject.OnNext(command);
    }
}

我想确保多个观察者不能订阅相同类型的命令。Rx 中是否有允许这样做的东西，或者我是否仅限于：a）自己查找类型或 b）在注册期间不处理它，并使用临时订阅者来检测多个注册？

Answer 1

我认为 Rx 没有为此提供任何内置机制。给定您的示例代码，我只需Dictionary<Type, IObserver<T>>在您的方法中创建一个并使用它Subscribe来强制执行您的约束。