操作符分级
按照官方的分类,操作符大致分为以下几种:
- Creating Observables(Observable 的创建操作符),比如:
Observable.create(),Observable.just(),Observable.from()等 - Transfroming Observable (Observable的转换操作符),比如:
Observable.map(),Observable.flatMap(),Observable.buffer()等 - Filter Observables(Observable的过滤操作符),比如:
Observable.filter(),Observable.sample(),Observable.take()等; - Combining Observables(Observable的组合操作符),比如:
Observable.join(),Observable.merge(),Observable.combineLatest()等;
Error Handling Operators(Obserzble的错误处理操作符),比如:
observable.onErrerResumeNext(),observable.retry()等; - Observable Utility Operators(Observable的功能性操作符),比如:
observable.subscribleOn(),observable.observeOn(),observable.delay()等; - Conditional and Bollean Operators(Observable的条件操作符),比如:
observable.amb(),observable.contains(),observable.skipUntil()等;
Mathematical and Aggregate Operators(Observable数学运算及聚合操作符),比如:observable.count()、observable.reduce()、observable.concat()等等;
其他如observable.toList()、observable.connect()、observable.publish()等等;
看这篇文章很详细:
http://www.bubuko.com/infodetail-847631.html
just()
可以将一个函数作为参数传给just()方法,你将会得到一个已存在代码的原始Observable版本。在一个新的响应式框架的基础上迁移已存在的代码,这个方法肯能是一个有用的开始点。
repeat()
repeat操作符就是对某一个Observable重复产生多次结果,当repeat() 接收到onComplete()会触发重订阅,默认情况下运行在一个新的线程上.