本頁展示的操作符用于對整個序列執(zhí)行算法操作或其它操作,由于這些操作必須等待數(shù)據(jù)發(fā)射完成(通常也必須緩存這些數(shù)據(jù)),它們對于非常長或者無限的序列來說是危險的,不推薦使用。
rxjava-math
模塊的操作符averageInteger(?)
— 求序列平均數(shù)并發(fā)射averageLong(?)
— 求序列平均數(shù)并發(fā)射averageFloat(?)
— 求序列平均數(shù)并發(fā)射averageDouble(?)
— 求序列平均數(shù)并發(fā)射max(?)
— 求序列最大值并發(fā)射maxBy(?)
— 求最大key對應(yīng)的值并發(fā)射min(?)
— 求最小值并發(fā)射minBy(?)
— 求最小Key對應(yīng)的值并發(fā)射sumInteger(?)
— 求和并發(fā)射sumLong(?)
— 求和并發(fā)射sumFloat(?)
— 求和并發(fā)射sumDouble(?)
— 求和并發(fā)射concat(?)
— 順序連接多個Observablescount(?)
and countLong(?)
— 計算數(shù)據(jù)項的個數(shù)并發(fā)射結(jié)果reduce(?)
— 對序列使用reduce()函數(shù)并發(fā)射最終的結(jié)果collect(?)
— 將原始Observable發(fā)射的數(shù)據(jù)放到一個單一的可變的數(shù)據(jù)結(jié)構(gòu)中,然后返回一個發(fā)射這個數(shù)據(jù)結(jié)構(gòu)的ObservabletoList(?)
— 收集原始Observable發(fā)射的所有數(shù)據(jù)到一個列表,然后返回這個列表toSortedList(?)
— 收集原始Observable發(fā)射的所有數(shù)據(jù)到一個有序列表,然后返回這個列表toMap(?)
— 將序列數(shù)據(jù)轉(zhuǎn)換為一個Map,Map的key是根據(jù)一個函數(shù)計算的toMultiMap(?)
— 將序列數(shù)據(jù)轉(zhuǎn)換為一個列表,同時也是一個Map,Map的key是根據(jù)一個函數(shù)計算的