这个页面展示了可用于对Observable发射的数据执行变换操作的各种操作符。
* [**`map( )`**](Map.md) — 对序列的每一项都应用一个函数来变换Observable发射的数据序列
* [**`flatMap( )`, `concatMap( )`, and `flatMapIterable( )`**](FlatMap.md) — 将Observable发射的数据集合变换为Observables集合,然后将这些Observable发射的数据平坦化的放进一个单独的Observable
* [**`switchMap( )`**](FlatMap.md) — 将Observable发射的数据集合变换为Observables集合,然后只发射这些Observables最近发射的数据
* [**`scan( )`**](Scan.md) — 对Observable发射的每一项数据应用一个函数,然后按顺序依次发射每一个值
* [**`groupBy( )`**](GroupBy.md) — 将Observable分拆为Observable集合,将原始Observable发射的数据按Key分组,每一个Observable发射一组不同的数据
* [**`buffer( )`**](Buffer.md) — 它定期从Observable收集数据到一个集合,然后把这些数据集合打包发射,而不是一次发射一个
* [**`window( )`**](Window.md) — 定期将来自Observable的数据分拆成一些Observable窗口,然后发射这些窗口,而不是每次发射一项
* [**`cast( )`**](Map.md) — 在发射之前强制将Observable发射的所有数据转换为指定类型
- ReactiveX
- Observables
- Single
- Subject
- Scheduler
- Operators
- 创建操作
- Create
- Defer
- Empty/Never/Throw
- From
- Interval
- Just
- Range
- Repeat
- Start
- Timer
- 变换操作
- Buffer
- FlatMap
- GroupBy
- Map
- Scan
- Window
- 过滤操作
- Debounce
- Distinct
- ElementAt
- Filter
- First
- IgnoreElements
- Last
- Sample
- Skip
- SkipLast
- Take
- TakeLast
- 结合操作
- And/Then/When
- CombineLatest
- Join
- Merge
- StartWith
- Switch
- Zip
- 错误处理
- Catch
- Retry
- 辅助操作
- Delay
- Do
- Materialize/Dematerialize
- ObserveOn
- Serialize
- Subscribe
- SubscribeOn
- TimeInterval
- Timeout
- Timestamp
- Using
- To
- 条件和布尔操作
- All/Contains/Amb
- DefaultIfEmpty
- SequenceEqual
- SkipUntil/SkipWhile
- TakeUntil/TakeWhile
- 算术和聚合操作
- Average/Concat/Reduce
- Max/Min/Count/Sum
- 异步操作
- 连接操作
- Connect
- Publish
- RefCount
- Replay
- 转换操作
- 阻塞操作
- 字符串操作
- 按字母顺序的操作符列表
- RxJava文档和教程
- RxJava入门指南
- RxJava使用示例
- 实现自定义操作符
- 自定义插件
- Backpressure
- 错误处理
- Android模块
- 参与开发
- 补充阅读材料