RxJava - 筛选运算符

在 RxJava 中，筛选运算符可以帮助你从有组合的和来自多个可观测对象的数据流中选择所需的数据。

以下是一些常用的筛选运算符：

filter

filter 运算符用于过滤数据流中不需要的值。传入一个判断式，只有满足该判断式的值会被传递给下游。

Observable.just(1, 2, 3, 4, 5)
    .filter(integer -> integer % 2 == 0)
    .subscribe(integer -> System.out.println(integer));
// Output: 2, 4

在上面的示例中，我们只保留了偶数，筛选出了值为 2 和 4 的元素。

ofType

ofType 运算符用于过滤指定类型的对象。只会传递指定类型的对象，其他类型的对象会被过滤掉。

Observable.just(1, "Hello", 3.14f, false)
    .ofType(String.class)
    .subscribe(string -> System.out.println(string));
// Output: Hello

在上面的示例中，我们使用 ofType 运算符指定只保留类型为字符串的对象，值为 Integer、Float 和 Boolean 的对象都被过滤掉了。

take

take 运算符可以通过指定数量，从流中取出前几个元素。

Observable.just(1, 2, 3, 4, 5)
    .take(3)
    .subscribe(integer -> System.out.println(integer));
// Output: 1, 2, 3

在上面的示例中，我们使用 take 运算符指定只保留前三个元素，值为 4 和 5 的元素被过滤掉了。

skip

skip 运算符可以通过指定数量，跳过流中的前几个元素。

Observable.just(1, 2, 3, 4, 5)
    .skip(2)
    .subscribe(integer -> System.out.println(integer));
// Output: 3, 4, 5

在上面的示例中，我们使用 skip 运算符跳过前两个元素，值为 1 和 2 的元素被过滤掉了。

distinct

distinct 运算符用于去除流中的重复元素，只会传递不同的元素。

Observable.just(1, 2, 2, 3, 4, 4, 4, 5)
    .distinct()
    .subscribe(integer -> System.out.println(integer));
// Output: 1, 2, 3, 4, 5

在上面的示例中，我们使用 distinct 运算符去除了重复元素，结果只包含了不同的元素。

debounce

debounce 运算符用于去除流中的抖动，只保留流中的稳定值。可以用于去除输入框的抖动或者减少频繁网络请求。

Observable.create((ObservableOnSubscribe<String>) emitter -> {
    emitter.onNext("T");
    Thread.sleep(100);
    emitter.onNext("Th");
    Thread.sleep(300);
    emitter.onNext("Thr");
    Thread.sleep(200);
    emitter.onNext("Thre");
    Thread.sleep(500);
    emitter.onNext("Three");
    Thread.sleep(100);
    emitter.onNext("Thre");
    Thread.sleep(300);
    emitter.onNext("Th");
    Thread.sleep(200);
    emitter.onNext("T");
    emitter.onComplete();
})
.debounce(300, TimeUnit.MILLISECONDS)
.subscribe(string -> System.out.println(string));
// Output: Three

在上面的示例中，我们模拟了一个输入框输入 "Thr" 后快速删除的操作，debounce 运算符会去除这些快速变化的值，只保留停留时间较长的值 "Three"。

以上就是 RxJava 中常用的筛选运算符介绍。这些运算符可以通过组合、嵌套、全局传递等方式，构成丰富的筛选逻辑，来适应不同的开发需求。