dart - 如何有条件地向 RxDart 中的 Observable 添加错误?
问题描述
使用 Dart StreamTransformer,我可以评估一个流值并选择基于某些条件(例如sink.add(value)
)发出它,或者添加一个错误(例如sink.addError('Enter a valid number')
)。
使用 RxDart 的流利操作符,我将如何做到最好?我可以.map
用来评估价值并addError('message')
针对主题使用。但是,有没有更好的方法?
解决方案
Stream.map
将抛出的异常作为流中的错误事件转发。
var result = values.map(
(value) => someCondition(value) ? value : throw 'Enter a valid number ');
推荐阅读
- python - 在 Python 中处理 CSV 文件 - 零导入/无库
- c# - 在 linq 查询中对多个列进行内部联接的类型推断错误
- gemfile - Gemfire - 如何限制/限制区域的 OQL 查询
- typo3 - 已弃用:自动 TCA 迁移
- sql - 选择来自不同状态的 2 列
- python - 使用 Python 将整个数据框除以 2
- gitlab-ci - gitlab管道挂起,失败
- android - 即使指定了“match_parent”,使用 ConstraintLayout 的 RecyclerView 项目也不会填满屏幕的整个宽度
- rename - 如何为回归输出中的系数创建名称?
- python - Plotly 绘图未显示在 HTML 文件中