上一篇文章中我们介绍了map操作符，其实还是比较简单的，本文将介绍稍微复杂一点的操作符flatmap。
怎么使用？
比如我们现在有这样一个需求，我们现在有一个Person的集合，每一个Person里面都有多个收货地址Address，现在我们想打印出收货地址。第一种实现方式
private void test5() {
List<Person> persons = new ArrayList<>();
List<Address> zhangsanAddress = new ArrayList<>();
zhangsanAddress.add(new Address("北京"));
zhangsanAddress.add(new Address("上海"));
zhangsanAddress.add(new Address("深圳"));
final Person person = new Person("zhangsan", zhangsanAddress);
List<Address> lisiAddress = new ArrayList<>();
lisiAddress.add(new Address("合肥"));
lisiAddress.add(new Address("杭州"));
lisiAddress.add(new Address("广州"));
Person person2 = new Person("lisi", lisiAddress);
persons.add(person);
persons.add(person2);
Observable.from(persons).subscribe(new Subscriber<Person>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(Person person) {
for (Address address : person.getAddresses()) {
Log.e(TAG, "onNext: person = " + person.getName() + "---address = " + address.getAddressName());
}
}
});
}虽然看起来还是挺简单的，但是我们现在不想在onNext方法里面写for循环，而是希望 Subscriber 中直接传入单个的 Address 对象呢？用 map() 显然是不行的，因为 map() 是一对一的转化，而我现在的要求是一对多的转化。那怎么才能把一个 Person 转化成多个 Student 呢？
利用flatmap代码如下：
Observable
.from(persons)
.flatMap(new Func1<Person, Observable<Address>>() {
@Override
public Observable<Address> call(Person person) {
return Observable.from(person.getAddresses());
}
})
.subscribe(new Subscriber<Address>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(Address address) {
Log.e(TAG, "onNext: address = " + address.getAddressName());
}
});从上面的代码可以看出， flatMap() 和 map() 有一个相同点：它也是把传入的参数转化之后返回另一个对象。但需要注意，和 map() 不同的是， flatMap() 中返回的是个 Observable 对象，并且这个 Observable 对象并不是被直接发送到了 Subscriber 的回调方法中。 flatMap() 的原理是这样的：1. 使用传入的事件对象创建一个 Observable 对象；2. 并不发送这个 Observable, 而是将它激活，于是它开始发送事件；3. 每一个创建出来的 Observable 发送的事件，都被汇入同一个 Observable ，而这个 Observable 负责将这些事件统一交给 Subscriber 的回调方法。这三个步骤，把事件拆成了两级，通过一组新创建的 Observable 将初始的对象『铺平』之后通过统一路径分发了下去。而这个『铺平』就是 flatMap() 所谓的 flat。