Observable 对象 observable.object(props) & observable.shallowObject(props) 名称参数 Observable 对象 如果把一个普通的 JavaScript 对象传递给 observable 方法，对象的所有属性都将被拷贝至一个克隆对象并将克隆对象转变成可观察的。(普通对象是...

To getIterator toFuture toIterable toList toMap toMultiMap toSortedList nest To 将Observable转换为另一个对象或数据结构 ReactiveX的很多语言特定实现都有一种操作符让你可以将Observable或者Observable发射的数据序列转...

StringObservable 类包含一些用于处理字符串序列和流的特殊操作符，如下： byLine( ) — 将一个字符串的Observable转换为一个行序列的Observable，这个Observable将原来的序列当做流处理，然后按换行符分割 decode( ) — 将一个多字节的字符流转换为一个Observable，它按字符边界...

热&冷的 Observables 由冷及热 - 凯蒂·佩里模式 暖的 Observables 天生的热 observables 共享 热&冷的 Observables Observable 有冷热两种类型。我们先来看看什么是冷的 observable 。如果是冷的 observable 的话，那么两个订阅者得到值是两份完全相同的副本，示例如下...

API RxSwift支持的操作符 创建 Observables 变换操作 过滤操作 结合操作 错误处理 辅助操作 条件和布尔操作 算数和聚合操作 连接操作 RxCocoa extensions API RxSwift支持的操作符 有时候，同一个操作符会有多个别名，不同平台或实现有时也会让同一个操作符有不同的名字。有的是历史...

按字母顺序排列的全部操作符列表 按字母顺序排列的全部操作符列表 aggregate( ) — see reduce( ) all( ) — determine whether all items emitted by an Observable meet some criteria amb( ) — given two or ...

sample signature: sample(sampler: Observable): Observable Sample from source when provided observable emits. Examples Example 1: Sample source every 2 seconds Example 2: Sample...

retryWhen 签名: retryWhen(receives: (errors: Observable) => Observable, the: scheduler): Observable 当发生错误时，基于自定义的标准来重试 observable 序列。 示例 示例 1: 在指定的时间间隔后触发重试 示例 2: 时间间隔增加的自定义重试 ...

Replay Replay 保证所有的观察者收到相同的数据序列，即使它们在Observable开始发射数据之后才订阅 可连接的Observable (connectable Observable)与普通的Observable差不多，不过它并不会在被订阅时开始发射数据，而是直到使用了Connect 操作符时才会开始。用这种方法，你可以在任何时候让...

forkJoin signature: forkJoin(...args, selector : function): Observable When all observables complete, emit the last emitted value from each. Why use forkJoin ? Examples Example...