这个页面列出了很多用于Observable的辅助操作符
materialize( )
— 将Observable转换成一个通知列表convert an Observable into a list of Notificationsdematerialize( )
— 将上面的结果逆转回一个Observabletimestamp( )
— 给Observable发射的每个数据项添加一个时间戳serialize( )
— 强制Observable按次序发射数据并且要求功能是完好的cache( )
— 记住Observable发射的数据序列并发射相同的数据序列给后续的订阅者observeOn( )
— 指定观察者观察Observable的调度器subscribeOn( )
— 指定Observable执行任务的调度器doOnEach( )
— 注册一个动作,对Observable发射的每个数据项使用doOnCompleted( )
— 注册一个动作,对正常完成的Observable使用doOnError( )
— 注册一个动作,对发生错误的Observable使用doOnTerminate( )
— 注册一个动作,对完成的Observable使用,无论是否发生错误doOnSubscribe( )
— 注册一个动作,在观察者订阅时使用doOnUnsubscribe( )
— 注册一个动作,在观察者取消订阅时使用finallyDo( )
— 注册一个动作,在Observable完成时使用delay( )
— 延时发射Observable的结果delaySubscription( )
— 延时处理订阅请求timeInterval( )
— 定期发射数据using( )
— 创建一个只在Observable生命周期存在的资源single( )
— 强制返回单个数据,否则抛出异常singleOrDefault( )
— 如果Observable完成时返回了单个数据,就返回它,否则返回默认数据toFuture( )
,toIterable( )
,toList( )
— 将Observable转换为其它对象或数据结构