相关疑难解决方法(0)

为什么RX有以下语法OnNext* (OnError|OnCompleted)？而不是(OnNext|OnError)* OnCompleted？这是从实现的角度来看很清楚(这也与通用语义IEnumerable和yield),但我想从现实生活中的情况不同.在现实生活中 - 生产者生成混合的数据流和异常(异常不会破坏生产者).

问题:如果我理解正确,唯一可行的解​​决方案是使可观察的返回复杂数据结构从初始数据和生成的异常(Observable.Timestamp()并.TimeInterval()具有类似的概念)结合起来,还是有其他选择？

目前我得出了以下解决方案:在可观察的生产者内部我手动处理exeptions并将它们传递给以下数据结构,这是我可观察的结果

public class ValueOrException<T>
{
    private readonly Exception ex;
    private readonly T value;

    public ValueOrException(T value, Exception ex)
    {
        this.value = value;
        this.ex = ex;
    }

    public ValueOrException(T value)
    {
        this.value = value;
    }

    public T Value
    {
        get { return this.value; }
    }

    public Exception Ex
    {
        get { return this.ex; }
    }
}