-
— 在数据序列的开头增加一项数据startWith( )
-
— 将多个Observable合并为一个merge( )
-
— 合并多个Observables,让没有错误的Observable都完成后再发射错误通知mergeDelayError( )
-
— 使用一个函数组合多个Observable发射的数据集合,然后再发射这个结果zip( )
-
,and( )
, andthen( )
— (when( )
) 通过模式和计划组合多个Observables发射的数据集合rxjava-joins
-
— 当两个Observables中的任何一个发射了一个数据时,通过一个指定的函数组合每个Observable发射的最新数据(一共两个数据),然后发射这个函数的结果combineLatest( )
-
andjoin( )
— 无论何时,如果一个Observable发射了一个数据项,只要在另一个Observable发射的数据项定义的时间窗口内,就将两个Observable发射的数据合并发射groupJoin( )
-
— 将一个发射Observables的Observable转换成另一个Observable,后者发射这些Observables最近发射的数据switchOnNext( )
() — 表示这个操作符当前是可选的
rxjava-joins
包的一部分,还没有包含在标准的RxJava操作符集合里
rxjava-joins