RxJava操作符
- map() 操作符就是用于变换Observable对象的，map操作符返回一个Observable对象，这样就可以实现链式调用，在一个Observable对象上多次使用map操作符，最终将最简洁的数据传递给Subscriber对象
- from() 接收一个集合作为输入，然后每次输出一个元素给subscriber
- flatmap() Observable.flatMap()接收一个Observable的输出作为输入，同时输出另外一个Observable
- filter 过滤,把不符合条件的过滤掉,留下符合条件的
- take 指定最多输出的数量
- doOnNext 允许我们在每次输出一个元素之前做一些额外的事情
示例一
- create() 创建
- subscribe() 订阅
- just()
- from() 尽管与just一样是创建操作符，但是from操作符稍微强大点。因为from操作符的作用是将传入的数组或 Iterable 拆分成具体对象后，依次发送出来。
// TODO: 2016/12/16 创建被观察者 observerable
Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext("111");
subscriber.onNext("222");
subscriber.onNext("333");
subscriber.onNext("444");
subscriber.onCompleted();
}});
//// TODO: 2016/12/16 等价于just() from()
Observable.just("111", "222", "333");
Observable.from(new String[]{"111", "222", "333"});
// TODO: 2016/12/16 示例一 打印字符串数组
Observable.from(new String[]{"1", "2", "3"}).subscribe(new Action1<String>() { @Override
public void call(String s) {
DebugLog.i(s + "=====");
}});
class Course {
String name = "";
public Course(String name) { this.name = name; }
public String getCourse() { return " china " + name; }
}
class Student {
String name = "";
Course course[];
public Student(String name) {
this.name = name;
course = new Course[]{new Course(getName()), new Course(getName()), new Course(getName()), new Course(getName())};
}
public String getName() { return name; }
}
Student[] students = new Student[]{new Student("zhangsan"), new Student("lisi"), new Student("wangwu"), new Student("maliu")};
// TODO: 2016/12/16 flatmap 变换
Observer<Course> observer = new Observer<Course>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(Course course) {
DebugLog.i(course.name + "====");
}
};
Observable.from(students).flatMap(new Func1<Student, Observable<Course>>() {
@Override
public Observable<Course> call(Student student) {
return Observable.from(student.course); }})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(observer);
// TODO: 2016/12/16 lift实现 integer对象转换 string
observable.lift(new Observable.Operator<String, Integer>() {
@Override
public Subscriber<? super Integer> call(final Subscriber<? super String> subscriber) {
return new Subscriber<Integer>() {
@Override
public void onCompleted() {
subscriber.onCompleted();
}
@Override
public void onError(Throwable e) {
subscriber.onError(e);
}
@Override
public void onNext(Integer integer) {
subscriber.onNext(integer + "=============");
}
};
}
});
示例二
map()特性:
- 它不必返回Observable对象返回的类型，你可以使用map操作符返回一个发出新的数据类型的observable对象。
- 可以对一个Observable多次使用map
Observable.just("Hellp Map Operator")
.map(new Func1<String, Integer>() {
@Override
public Integer call(String s) {
return 2015;//通过第一个map转成Integer
}
}).map(new Func1<Integer, String>() {
@Override
public String call(Integer integer) {
return String.valueOf(integer);//再通过第二个map转成String
}
}).subscribe(new Action1<String>() {
@Override
public void call(String s) {
System.out.println(s);
}
});
示例三
Map是一对一的转换，那么有没有一对多的转换呢？当然有，就是现在要说的 FlatMap
FlatMap操作符使用一个指定的函数对原始Observable发射的每一项数据执行变换操作，这个函数返回一个本身也发射数据的Observable，然后FlatMap合并这些Observables发射的数据，最后将合并后的结果当做它自己的数据序列发射。
private final String url1 = "http://www.iamxiarui.com/wp-content/uploads/2016/06/套路.png";
private final String url2 = "http://www.iamxiarui.com/wp-content/uploads/2016/06/为什么我的流量又没了.png";
private final String url3 = "http://www.iamxiarui.com/wp-content/uploads/2016/05/cropped-iamxiarui.com_2016-05-05_14-42-31.jpg";
private final String url4 = "http://www.iamxiarui.com/wp-content/uploads/2016/05/微信.png";
//一组Url数据private final String[] urls = new String[]{url1, url2, url3, url4};
然后来看flatmap如何处理：
//先传递String类型的UrlObservable.from(urls) .flatMap(new Func1<String, Observable<String>>() {
@Override
public Observable<String> call(String s) {
return Observable.just(s); } })
.map(new Func1<String, Bitmap>() {
@Override
public Bitmap call(String s) {
//通过Map转换成Bitmap类型发送出去
return GetBitmapForURL.getBitmap(s);
} })
.subscribeOn(Schedulers.io()) // 指定subscribe()发生在IO线程 .observeOn(AndroidSchedulers.mainThread()) // 指定Subscriber的回调发生在UI线程 //可以看到，这里接受的类型是Bitmap，而不是String .subscribe(new Action1<Bitmap>() {
@Override
public void call(Bitmap bitmap) { mainImageView.setImageBitmap(bitmap); mainProgressBar.setVisibility(View.GONE);
}
});
