如何将多个错误传递到重播主题

Question

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

当我调用OnError时，只传递了第一个异常。我需要多次打电话，并让所有errors/exceptions都通过了。

我看到内部RX创建了一个AnonymousSafeObserver，OnError正在调用Dispose.

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

多谢。

Answer 1

不得将多个错误发送到 Rx 流中。Rx 的一个基本属性是可观察量表现出以下语法：

OnNext*(OnError|OnCompleted)?

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

AnonymousSafeObserver只是在强制执行这种不变性。

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