在方法上创建可观察的

不使用规则 Subject 更多的是一个没有很好表达的指导方针。

一般来说,如果你在使用主题 在内部 一条可以观察到的管道,那么你很可能做了一些错误的事情——这应该避免。

如果你用的是 主题 作为可观测数据的来源 和 正确封装 主题 和 你把它弄混了,那你就没事了。所以这通常意味着使用 private 只有您的代码才能访问的字段(因此没有人可以调用 .OnCompleted() 接电话和打电话 .AsObservable() 这样就没有人能把你的可观测数据 主题 .

在您的情况下,您直接订阅,所以不 .asobservable()。 需要,但我怀疑这只是演示代码。在现实世界中,一定要搞混了。

您的代码应该是这样的:

private Subject<MyObject3> _subject = new Subject<MyObject3>();

private void SetUpObservable()
{
    _subject = new Subject<MyObject3>();
    _subject.Subscribe(x => Console.WriteLine($"Message acknowledged"));
}

public virtual void MessageHandler(MyObject1 object1, MyObject2 object2)
{
    _subject.OnNext(new MyObject3(object1, object2));
}

现在,如果你仍然想避免 主题 然后您可以选择这样做:

private Action<MyObject3> _delegate;

private void SetUpObservable()
{
    Observable
        .FromEvent<MyObject3>(h => _delegate += h, h => _delegate -= h)
        .Subscribe(x => Console.WriteLine($"Message acknowledged"));
}

public virtual void MessageHandler(MyObject1 object1, MyObject2 object2)
{
    _delegate?.Invoke(new MyObject3(object1, object2));
}

在我看来 主题 给你更好的控制,更容易设置。

无论如何,您可能应该保留订阅 IDisposable 这样你就可以好好清理了。