返回

RxJava之map和flatMap的操作方法和理解

Android

RxJava中的map和flatMap的用法与区别

map操作符

map操作符是一个一元操作符，它接收一个函数作为参数，该函数对Observable发射的每一项数据应用一个变换操作。map操作符的语法如下：

<T, R> Observable<R> map(Function<T, R> func);

其中，T是Observable发射的数据类型，R是变换后的数据类型。

map操作符的使用方法非常简单，只需将一个函数作为参数传递给map方法即可。例如，以下代码将Observable发射的每个整数数据项乘以2：

Observable<Integer> observable = Observable.just(1, 2, 3, 4, 5);

Observable<Integer> transformedObservable = observable.map(new Function<Integer, Integer>() {
    @Override
    public Integer apply(Integer t) {
        return t * 2;
    }
});

transformedObservable.subscribe(new Observer<Integer>() {
    @Override
    public void onNext(Integer t) {
        System.out.println(t);
    }

    @Override
    public void onError(Throwable e) {

    }

    @Override
    public void onComplete() {

    }
});

输出结果为：

2
4
6
8
10

flatMap操作符

flatMap操作符是一个一元操作符，它接收一个函数作为参数，该函数将Observable发射的每一项数据转换成一个Observable。flatMap操作符的语法如下：

<T, R> Observable<R> flatMap(Function<T, Observable<R>> func);

其中，T是Observable发射的数据类型，R是变换后的数据类型。

flatMap操作符的使用方法也很简单，只需将一个函数作为参数传递给flatMap方法即可。例如，以下代码将Observable发射的每个整数数据项转换成一个Observable，该Observable发射该整数的平方和立方：

Observable<Integer> observable = Observable.just(1, 2, 3, 4, 5);

Observable<Integer> transformedObservable = observable.flatMap(new Function<Integer, Observable<Integer>>() {
    @Override
    public Observable<Integer> apply(Integer t) {
        return Observable.just(t * t, t * t * t);
    }
});

transformedObservable.subscribe(new Observer<Integer>() {
    @Override
    public void onNext(Integer t) {
        System.out.println(t);
    }

    @Override
    public void onError(Throwable e) {

    }

    @Override
    public void onComplete() {

    }
});

输出结果为：

1
8
4
64
9
727
16
256
25
1250

map和flatMap的区别

map操作符和flatMap操作符都是一元操作符，它们都可以对Observable发射的数据进行转换。但是，这两个操作符之间存在着本质的区别。

  • map操作符对Observable发射的每一项数据应用一个函数，执行变换操作。对原始的Observable发射的每一项数据应用相同的函数，以产生一个新的Observable。
  • flatMap操作符将Observable发射的每一项数据转换成一个Observable，然后将这些Observable合并成一个新的Observable。这意味着，flatMap操作符可以将一个Observable转换为另一个Observable，而map操作符只能将一个Observable转换为另一个Observable。

结论

map和flatMap是RxJava中非常常用的两个操作符，它们都可以对Observable发射的数据进行转换。但是，这两个操作符之间存在着本质的区别。map操作符对Observable发射的每一项数据应用一个函数，执行变换操作。对原始的Observable发射的每一项数据应用相同的函数，以产生一个新的Observable。flatMap操作符将Observable发射的每一项数据转换成一个Observable，然后将这些Observable合并成一个新的Observable。