Как условно добавить ошибку в Observable в RxDart?

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 ');