如何将多个错误传递给 ReplaySubject?
How can I pass multiple errors down a ReplaySubject?
如何将多个错误传递给 ReplaySubject
?
当我调用 OnError
时,只传递了第一个异常。我需要多次调用并通过所有 errors/exceptions
。
我在内部看到 RX
创建了一个 AnonymousSafeObserver
而 OnError
正在调用 Dispose
。
我可以创建自己的 AnonymousSafeObserver
版本吗?如何更改功能?
非常感谢。
您不得将多个错误发送到 Rx 流中。 Observables 表现出以下语法是 Rx 的基础 属性:
OnNext*(OnError|OnCompleted)?
也就是说,一个流由零个或多个 OnNext
事件组成,后跟可选的单个 OnError
或 OnCompleted
.
AnonymousSafeObserver
只是强制执行此不变量。
听起来您的错误实际上是流的 data 而不是流本身异常终止的信号。在这种情况下,创建一个类型来携带此数据并通过 OnNext
发送。
如何将多个错误传递给 ReplaySubject
?
当我调用 OnError
时,只传递了第一个异常。我需要多次调用并通过所有 errors/exceptions
。
我在内部看到 RX
创建了一个 AnonymousSafeObserver
而 OnError
正在调用 Dispose
。
我可以创建自己的 AnonymousSafeObserver
版本吗?如何更改功能?
非常感谢。
您不得将多个错误发送到 Rx 流中。 Observables 表现出以下语法是 Rx 的基础 属性:
OnNext*(OnError|OnCompleted)?
也就是说,一个流由零个或多个 OnNext
事件组成,后跟可选的单个 OnError
或 OnCompleted
.
AnonymousSafeObserver
只是强制执行此不变量。
听起来您的错误实际上是流的 data 而不是流本身异常终止的信号。在这种情况下,创建一个类型来携带此数据并通过 OnNext
发送。