dart - 如何有条件地向 RxDart 中的 Observable 添加错误？

Question

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

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

Answer 1

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

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