Rxjava中涉及到两个重要的角色，一：被观察者 二：观察者，我们知道当被观察者和观察者绑定后，被观察者就可以发送数据了，观察者就可以接收数据了，此文我们优先从如下几个方面做下介绍，并用适当的例子来进行具体的说明：
1 Rxjava通过哪些操作符接收数据源并创建一个被观察者对象。
2 优雅的通过Action替代Subscriber
3 map和flatmap的区别（通过举例说明）
接下来，我就来对上面几点做一个简单的说明，因为这些都是你想学习Rxjava所必须要掌握的知识点。
一 Rxjava通过哪些操作符接收数据源并创建一个被观察者对象。
1 Observable.just(T item)
Observable.just("a", "b") .
subscribe(new Subscriber<String>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(String s) {
Log.i(TAG, s);
}
});
2 Observable.fromArray(T ... item)
这里它和just有着相同的功能，都是接受数据源并创建一个被观察者对象。不同的是fromArray可以接受可变长参数对象（其实就是一个数组），它会把数组中的每个元素发射出来。just也是可以输入多个参数，但是是定长的，SDK内置了一些重载的方法，最多可以输入10个参数。
3 Observable.fromIterable(Iterable<? extends T> source)
此方法接收一个继承自Iterable接口的参数，简单的说就是java中的集合类。因此你可以 传入一个list集合等等
当然了，还有其他的几种情况，我们只需要知道这种方式创建的观察者，当订阅观察者以后，将会自动的发送数据。比传统的onnext的写法要快捷的多。
二 优雅的通过Action替代Subscriber
Observable.just("a", "b") .
subscribe(new Subscriber<String>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(String s) {
Log.i(TAG, s);
}
});
可以看到，我们这里只用了onNext(obj)，还有两个重写的onError(error)和onCompleted()并没有用到，这样导致我们多出了几行根本用不到的代码。于是就想能不能只写我们使用到的，其他几个没用到的就不写，这样的代码看着才舒服。接下来就是使用本次的主角Action来代替Subscriber
Action
上部分的代码使用Action来代替Subscriber得到的代码是这样的：
Observable.just("a", "b")
.subscribe(new Action1<String>() {
@Override
public void call(String s) {
Log.i(TAG, s);
}
});
是不是简洁多了。为什么可以这种转换呢，源码告诉我们，原来就是把Action对象转化成对应的Subscriber对象了
三 map和flatmap的区别（重点）
1 对于map，我们先看下面的示意图
通过分析下面的代码
Observable.just("a", "b", "c", "d", "e")
.map(new Function<String, String>() {
@Override
public String apply(String s) throws Exception {
Log.d(TAG,"apply===="+s);
return s + 1;
}
})
.subscribe(new Consumer<String>() {
@Override
public void accept(String s) throws Exception {
Log.d(TAG,"accept====="+s);
}
});
这段的输出如下：
通过map的分析图，看结果太简单了。
2 flatmap(重点、难点)
同样的我们先看下它的转换图
还是通过举例说明，下面的例子的需求是如何打印一个学生所学习的所有课程，我们先来看下如何通过flatmap来做，
由上图可以看出Student1、Student2经过flatMap后，按顺序依次经历了Observable1、Observable2，分别转化为Course。最后按顺序得到Course1、Course2、Course3、Course4、Course5、Course6，其中1-3由Student1得到，4-6由Student2得到。
结合代码和示意图，是不是对flatMap有了一定的理解。
注意：FlatMap对这些Observables发射的数据做的是合并(merge)操作，因此它们可能是交错的。也就说，传入的顺序可能跟出来的顺序不一样。
如果要保证顺的的话，可以使用concatMap。
再来分析下实体bean，如下：
public class Student {
public String name;
public List<Course> list;
}
public class Course {
public String id;
public String courseName;
}
我来添加学生，课程的测试数据，如下：
//添加学生，课程测试数据
public void addTestData(){
Student stu=new Student();
stu.name="小明";
List<Course> clist=new ArrayList<>();
Course c1=new Course();
c1.courseName="物理";
clist.add(c1);
Course c2=new Course();
c2.courseName="化学";
clist.add(c2);
Course c3=new Course();
c3.courseName="生物";
clist.add(c3);
stu.list=clist;
list.add(stu);
Student stu1=new Student();
stu1.name="小华";
List<Course> clist1=new ArrayList<>();
Course c4=new Course();
c4.courseName="政治";
clist1.add(c4);
Course c5=new Course();
c5.courseName="历史";
clist1.add(c5);
Course c6=new Course();
c6.courseName="地理";
clist1.add(c6);
stu1.list=clist1;
list.add(stu1);
}
关键代码段如下：
Observable.fromIterable(list)
.flatMap(new Function<Student, ObservableSource<Course>>() {
@Override
public ObservableSource<Course> apply(Student student) throws Exception {
return Observable.fromIterable(student.list);
}
}).subscribe(new Consumer<Course>() {
@Override
public void accept(Course course) throws Exception {
Log.d(TAG,course.courseName);
}
});
其运行的结果为：
上面我们分析了map和flatmap,那么他们有哪些相同点和不同点呢？
相同点：①都是依赖FuncX(入参，返回值)进行转换（将一个类型依据程序逻辑转换成另一种类型，根据入参和返回值）②都能在转换后直接被subscribe
不同点：①map返回的是结果集，flatmap返回的是包含结果集的Observable（返回结果不同）②map被订阅时每传递一个事件执行一次onNext方法，flatmap多用于多对多，一对多，再被转化为多个时，一般利用from/just进行一一分发，被订阅时将所有数据传递完毕汇总到一个Observable然后一一执行onNext方法（执行顺序不同）>>>>(如单纯用于一对一转换则和map相同)③map只能单一转换，单一只的是只能一对一进行转换，指一个对象可以转化为另一个对象但是不能转换成对象数组（map返回结果集不能直接使用from/just再次进行事件分发，一旦转换成对象数组的话，再处理集合/数组的结果时需要利用for一一遍历取出，而使用RxJava就是为了剔除这样的嵌套结构，使得整体的逻辑性更强。）flatmap既可以单一转换也可以一对多/多对多转换，flatmap要求返回Observable，因此可以再内部进行from/just的再次事件分发，一一取出单一对象（转换对象的能力不同）
