如何有条件地将错误添加到 RxDart 中的 Observable？答案

【问题标题】：How to conditionally add an error to an Observable in RxDart?如何有条件地将错误添加到 RxDart 中的 Observable？
【发布时间】：2019-05-14 10:48:47
【问题描述】：

使用 Dart StreamTransformer，我可以评估一个流值并选择基于某些条件（例如sink.add(value)）发出它，或者添加一个错误（例如sink.addError('Enter a valid number')）。

如何最好地使用 RxDart 的流利操作符来做到这一点？我可以使用.map 来评估价值并针对主题使用addError('message')。但是，有没有更好的方法？

【问题讨论】：

【解决方案1】：

Stream.map 会将抛出的异常作为错误事件转发到流中。

var result = values.map(
  (value) => someCondition(value) ? value : throw 'Enter a valid number ');

【讨论】：