- — 将上面的结果逆转回一个Observable
timestamp( )
— 给Observable发射的每个数据项添加一个时间戳- — 强制Observable按次序发射数据并且要求功能是完好的
cache( )
— 记住Observable发射的数据序列并发射相同的数据序列给后续的订阅者- — 指定观察者观察Observable的调度器
subscribeOn( )
— 指定Observable执行任务的调度器- — 注册一个动作,对正常完成的Observable使用
doOnError( )
— 注册一个动作,对发生错误的Observable使用- — 注册一个动作,对完成的Observable使用,无论是否发生错误
doOnSubscribe( )
— 注册一个动作,在观察者订阅时使用- — 注册一个动作,在观察者取消订阅时使用
finallyDo( )
— 注册一个动作,在Observable完成时使用- — 延时处理订阅请求
timeInterval( )
— 定期发射数据- — 创建一个只在Observable生命周期存在的资源
single( )
— 强制返回单个数据,否则抛出异常- — 如果Observable完成时返回了单个数据,就返回它,否则返回默认数据
toFuture( )
, ,toList( )
— 将Observable转换为其它对象或数据结构