c# - 如何将多个错误传递给 ReplaySubject？

Question

如何将多个错误传递给 ReplaySubject？

当我调用 OnError 时，只有第一个异常被传递。我需要多次调用并传递所有错误/异常。

我在内部看到 RX 创建了一个 AnonymousSafeObserver 并且 OnError 正在调用 Dispose。

我可以创建自己的 AnonymousSafeObserver 版本吗？如何更改功能？

非常感谢。

Answer 1

您不得将多个错误发送到一个 Rx 流中。 Observables 表现出以下语法是 Rx 的一个基本属性:

OnNext*(OnError|OnCompleted)?

也就是说，一个流由零个或多个 OnNext 事件组成，后跟可选的单个 OnError 或 OnCompleted。

AnonymousSafeObserver 只是强制执行此不变量。

听起来您的错误实际上是流的数据，而不是流本身异常终止的信号。在这种情况下，创建一个类型来承载此数据并改为通过 OnNext 发送。