Как условно добавить ошибку в 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 ');