摘要：这个方法可以将事件序列中的元素进行整合加工，返回一个新的被观察者。功能操作符延迟一段事件发送事件。在执行上述操作显示在线程执行上述准备操作在线程执行下面操作开始了指定被观察者的线程，要注意的时，如果多次调用此方法，只有第一次有效。
前言
本篇文章主要介绍Rxjava 2.x的一些常用的操作符,对Rxjava不熟悉的朋友可以先去看下我之前的两篇介绍
Android RxJava：基础介绍与使用
Android RxJava系列一: 基础常用详解
创建操作符create() 创建一个被观察者
public staticObservable create(ObservableOnSubscribe source)
Observableobservable = Observable.create(new ObservableOnSubscribe () { @Override public void subscribe(ObservableEmitter e) throws Exception { e.onNext("This is Observer"); //通过 ObservableEmitter 发射器向观察者发送事件。 e.onComplete(); } });
just() 创建一个被观察者，并发送事件，发送的事件不可以超过10个以上。
public staticObservable just(T item) ...... public static Observable just(T item1, T item2, T item3, T item4, T item5, T item6, T item7, T item8, T item9, T item10)
Observable.just(1, 2, 3)
.subscribe(new Observer < Integer > () {
@Override
public void onSubscribe(Disposable d) {
Log.d(TAG, "-------onSubscribe");
}
@Override
public void onNext(Integer integer) {
Log.d(TAG, "-------onNext " + integer);
}
@Override
public void onError(Throwable e) {
Log.d(TAG, "-------onError ");
}
@Override
public void onComplete() {
Log.d(TAG, "-------onComplete ");
}
});
使用just()方法创建Observable对象,Observable会将事件逐个发送
From 操作符
fromArray() 这个方法和 just() 类似，只不过 fromArray 可以传入一个数组
fromCallable() Callable 和 Runnable 的用法基本一致，只是它会返回一个结果值
fromIterable() 直接发送一个 List 集合数据给观察者
public staticObservable fromArray(T... items) Integer array[] = {1, 2, 3, 4}; Observable.fromArray(array) .subscribe(new Observer < Integer > () { @Override public void onSubscribe(Disposable d) { Log.d(TAG, "--------------onSubscribe"); } @Override public void onNext(Integer integer) { Log.d(TAG, "--------------onNext " + integer); } @Override public void onError(Throwable e) { Log.d(TAG, "--------------onError "); } @Override public void onComplete() { Log.d(TAG, "--------------onComplete "); } });
public staticObservable fromCallable(Callable supplier) Observable.fromCallable(new Callable < Integer > () { @Override public Integer call() throws Exception { return 1; } }) .subscribe(new Consumer < Integer > () { @Override public void accept(Integer integer) throws Exception { Log.d(TAG, "--------------accept " + integer); } });
public staticObservable fromIterable(Iterable source) List list = new ArrayList<>(); list.add(0); list.add(1); list.add(2); list.add(3); Observable.fromIterable(list) .subscribe(new Observer < Integer > () { @Override public void onSubscribe(Disposable d) { Log.d(TAG, "--------------onSubscribe"); } @Override public void onNext(Integer integer) { Log.d(TAG, "--------------onNext " + integer); } @Override public void onError(Throwable e) { Log.d(TAG, "--------------onError "); } @Override public void onComplete() { Log.d(TAG, "--------------onComplete "); } });
empty() 直接发送 onComplete() 事件
Observable.empty()
.subscribe(new Observer < Object > () {
@Override
public void onSubscribe(Disposable d) {
Log.d(TAG, "---------------------onSubscribe");
}
@Override
public void onNext(Object o) {
Log.d(TAG, "---------------------onNext");
}
@Override
public void onError(Throwable e) {
Log.d(TAG, "---------------------onError " + e);
}
@Override
public void onComplete() {
Log.d(TAG, "==================onComplete");
}
});
转换操作符
map() map 可以将被观察者发送的数据类型转变成其他的类型,是一对一的转换
public finalObservable map(Function mapper) //将 Integer 类型的数据转换成 String。 Observable.just(1, 2, 3) .map(new Function < Integer, String > () { @Override public String apply(Integer integer) throws Exception { return integer+"rxjava"; } }) .subscribe(new Observer < String > () { @Override public void onSubscribe(Disposable d) { Log.e(TAG, "----------------------onSubscribe"); } @Override public void onNext(String s) { Log.e(TAG, "----------------------onNext " + s); } @Override public void onError(Throwable e) { Log.d(TAG, "---------------------onError " + e); } @Override public void onComplete() { Log.d(TAG, "---------------------onComplete" ); } });
flatMap() 这个方法可以将事件序列中的元素进行整合加工，返回一个新的被观察者。
public finalObservable flatMap(Function> mapper)
flatMap() 其实与 map() 类似，但是 flatMap() 返回的是一个 Observerable。现在用一个map()的例子和flatMap()的例子来对比说明 flatMap() 的用法。
需求:我们现在需要通过学校拿到院系列表,然后在每个院系中拿到学生的信息.
传统的实现方式有很多种,我就不举例了,直接使用Rxjava实现:
//学校
class School{
private String name;
private List departments;
public School(){}
public School(String name, List departments) {
this.name = name;
this.departments = departments;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public List getDepartments() {
return departments;
}
public void setDepartments(List departments) {
this.departments = departments;
}
}
//院系
class Department{
private String name;
private List students;
public Department(){}
public Department(String name, List students) {
this.name = name;
this.students = students;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public List getStudents() {
return students;
}
public void setStudents(List students) {
this.students = students;
}
}
//学生
class Student {
private String name;
private String school;
public Student(){}
public Student(String name, String school) {
this.name = name;
this.school = school;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getSchool() {
return school;
}
public void setSchool(String school) {
this.school = school;
}
}
使用map()方法实现:
//使用map()实现方式
Observable.fromIterable(departments)
.map(new Function>() {
@Override
public List apply(Department department) throws Exception {
return department.getStudents();
}
})
.subscribe(new Observer>() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onNext(List students) {
for (Student student : students){
Log.d("----------", student.getName()+student.getSchool() );
//如果还需要获取学生所有课程以及成绩
......................
}
}
@Override
public void onError(Throwable e) {
}
@Override
public void onComplete() {
}
});
//使用flatMap()实现
Observable.fromIterable(departments)
.flatMap(new Function>() {
@Override
public ObservableSource apply(Department department) throws Exception {
return Observable.fromIterable(department.getStudents());
}
})
.flatMap() //如果还需要获取学生所有课程以及成绩操作
.subscribe(new Observer() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onNext(Student student) {
Log.d("---------",student.getName()+student.getSchool());
}
@Override
public void onError(Throwable e) {
}
@Override
public void onComplete() {
}
});
以上代码中map()方法实现中,可以看到我们在onNext()方法中使用了for循环.如果代码逻辑在复杂一些,就可能需要嵌套for循环来实现,那就真的迷之缩进了,而使用flatMap()方法实现,只需要实现一个flatMap()转换一下就好了,随着代码逻辑增加,代码依然清晰,这就是flatMap()的强大之处,也是很多人喜欢使用Rxjava的原因所在.
concatMap()
concatMap() 和 flatMap() 基本上是一样的，只不过 concatMap() 转发出来的事件是有序的，而 flatMap() 是无序的。
