创建操作 Create 创建操作 Create 使用一个函数从头开始创建一个Observable 你可以使用Create 操作符从头开始创建一个Observable，给这个操作符传递一个接受观察者作为参数的函数，编写这个函数让它的行为表现为一个Observable—恰当的调用观察者的onNext，onError和onCompleted方法...

MobX 会对什么作出反应? MobX 追踪属性访问，而不是值 示例 正确的: 在追踪函数内进行间接引用 错误的: 改变了非 observable 的引用 错误的: 在追踪函数外进行间接引用 正确的: 在追踪函数内进行间接引用 错误的: 存储 observable 对象的本地引用而不对其追踪 常见陷阱: console.log 正确的: 在追踪...

Subscribe foreach BlockingObservable Subscribe 操作来自Observable的发射物和通知 Subscribe 操作符是连接观察者和Observable的胶水。一个观察者要想看到Observable发射的数据项，或者想要从Observable获取错误和完成通知，它首先必须使用这个操作符订阅那个Obs...

Observable 映射 observable.map(values, options?) observable.map(values, { deep: false }) observable.map(values, { name: "my map" }) Observable 映射 observable.map(values, o...

retryWhen signature: retryWhen(receives: (errors: Observable) => Observable, the: scheduler): Observable Retry an observable sequence on error based on custom criteria. Examples...

Operators combination combineLatest Business case concat merge zip Business case Operators combination There are many operators out there that allows you to combine the v...

条件操作符 布尔操作符 这个页面的操作符可用于根据条件发射或变换Observables，或者对它们做布尔运算： 条件操作符 amb( ) — 给定多个Observable，只让第一个发射数据的Observable发射全部数据 defaultIfEmpty( ) — 发射来自原始Observable的数据，如果原始Observable...

concat 签名: concat(observables: ...*): Observable 按照顺序，前一个 observable 完成了再订阅下一个 observable 并发出值。 示例 示例 1: concat 2个基础的 observables 示例 2: concat 作为静态方法 示例 3: 使用延迟的 souce observa...

很多操作符可用于对Observable发射的onError 通知做出响应或者从错误中恢复，例如，你可以： 吞掉这个错误，切换到一个备用的Observable继续发射数据 吞掉这个错误然后发射默认值 吞掉这个错误并立即尝试重启这个Observable 吞掉这个错误，在一些回退间隔后重启这个Observable 这是操作符列表： onErrorRes...

last 签名: last(predicate: function): Observable 根据提供的表达式，在源 observable 完成时发出它的最后一个值。 示例 示例 1: 序列中的最后一个值 示例 2: 最后一个通过 predicate 函数的值 示例 3: 使用结果选择器的 last 示例 4: 使用默认值的 last 其他...