-
filter( )
— 过滤数据 -
takeLast( )
— 只发射最后的N项数据 -
last( )
— 只发射最后的一项数据 -
lastOrDefault( )
— 只发射最后的一项数据,如果Observable为空就发射默认值 -
takeLastBuffer( )
— 将最后的N项数据当做单个数据发射 -
skip( )
— 跳过开始的N项数据 -
skipLast( )
— 跳过最后的N项数据 -
take( )
— 只发射开始的N项数据 -
first( )
andtakeFirst( )
— 只发射第一项数据,或者满足某种条件的第一项数据 -
firstOrDefault( )
— 只发射第一项数据,如果Observable为空就发射默认值 -
elementAt( )
— 发射第N项数据 -
elementAtOrDefault( )
— 发射第N项数据,如果Observable数据少于N项就发射默认值 -
sample( )
orthrottleLast( )
— 定期发射Observable最近的数据 -
throttleFirst( )
— 定期发射Observable发射的第一项数据 -
throttleWithTimeout( )
ordebounce( )
— 只有当Observable在指定的时间后还没有发射数据时,才发射一个数据 -
timeout( )
— 如果在一个指定的时间段后还没发射数据,就发射一个异常 -
distinct( )
— 过滤掉重复数据 -
distinctUntilChanged( )
— 过滤掉连续重复的数据 -
ofType( )
— 只发射指定类型的数据 -
ignoreElements( )
— 丢弃所有的正常数据,只发射错误或完成通知