如何避免在 RX 中使用 Subjects

Question

所以我一直在到处读到 Subject<T> 的使用是“不好的”——我有点同意这个推理。

但是，我正在想办法避免使用它并举个例子。

目前，我的持久化配置类有一个抽象类，它上面有一个受保护的Save() 方法，只要更改属性应该持久化类，就会调用该方法。此消息将消息泵送到Subject<T> 上，该消息通过IObservable<T> 接口公开，序列化服务侦听该接口并序列化该类。这在当时似乎是最明显、最简单、最快捷的实现方式。

那么不使用主题的 RX 方法是什么？我会改为公开一个事件并使用Observable.FromEventPattern() 订阅它吗？ - 因为这似乎是一种更复杂的方法。

Answer 1

Subject<T> 的使用并不是那么糟糕——必须有某种“进入 monad”的方式——这是学术上的说法“得到一个IObservable<T>” .你需要从某个地方开始。

Subject<T> 的问题更多地出现在从订阅中使用而不是将现有的 observable 链接在一起时。受试者应该存在于您的 Rx 机器的边缘。

如果提供的入口点（例如FromEvent、FromEventPattern、FromAsync、Return、ToObservable() 等）都不适合您，那么使用 Subject<T> 是完全有效的。并且没有必要仅仅为了方便使用上述之一而增加额外的复杂性——无论如何，它们中的大多数都使用主题或类似主题的结构。

在你的情况下，听起来像Subject<T> 就好了。您可能需要通过AsObservable() 公开它以隐藏实现细节。

Answer 2

进入 observable 的简单方法是通过 Action

private Action<ObservableArgs> _action;

创建可观察对象

public IObservable<ObservableArgs> GetObservable()
{
    return Observable.FromEvent<ObservableArgs>>(
                ev => _action += ev, 
                ev => _action -= ev);
}

然后使用添加到可观察对象

public void OnNext(ObservableArgs args)
{
    _action?.Invoke(args);
}