Filtering Observables

这个页面展示的操作符可用于过滤和选择Observable发送的数据序列。

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