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

How can I pass multiple errors down a ReplaySubject?

如何将多个错误传递给 ReplaySubject

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

我在内部看到 RX 创建了一个 AnonymousSafeObserverOnError 正在调用 Dispose

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

非常感谢。

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

OnNext*(OnError|OnCompleted)?

也就是说,一个流由零个或多个 OnNext 事件组成,后跟可选的单个 OnErrorOnCompleted.

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

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