1.examples
public static void hello(String... names) { Observable.from(names).subscribe(new Action1<String>() { @Override public void call(String s) { System.out.println("Hello " + s + "!"); } }); }
输入：hello("Ben", "George");
输出：
Hello Ben!
Hello George!
2.explain
监控names，触发next。
3.在Android中应用
RxJava相当于注册一个listener event。
3.1创建 Subscriber
Subscriber<String> subscriber = new Subscriber<String>() { @Override public void onNext(String s) { Log.d(tag, "Item: " + s); } @Override public void onCompleted() { Log.d(tag, "Completed!"); } @Override public void onError(Throwable e) { Log.d(tag, "Error!"); }};
或
Observer<String> observer = new Observer<String>() { @Override public void onNext(String s) { Log.d(tag, "Item: " + s); } @Override public void onCompleted() { Log.d(tag, "Completed!"); } @Override public void onError(Throwable e) { Log.d(tag, "Error!"); }};
Observer比Subscriber少两个功能：onStart()+unsubscribe()。
Subscriber即观察者，它决定事件触发的时候将有怎样的行为。可以理解为被动输出者。
3.2创建Observable
Observable observable = Observable.just("Hello", "Hi", "Aloha");
或
`
String[] words = {"Hello", "Hi", "Aloha"};
Observable observable = Observable.from(words);
`
Observable 被观察者，可以理解为输入者。
3.3订阅
observable.subscribe(observer); observable.subscribe(subscriber);
联系3.1与3.2.执行onnext。
4.简单例子
4.1 打印
`
String[] names = ...;
Observable.from(names) .subscribe(new Action1<String>() {
@Override public void call(String name) {
Log.d(tag, name); }
});
`
4.2图片展示
`
int drawableRes = ...;
ImageView imageView = ...;
Observable.create(new OnSubscribe<Drawable>() {
@Override public void call(Subscriber<? super Drawable> subscriber) {
Drawable drawable = getTheme().getDrawable(drawableRes));
subscriber.onNext(drawable);
subscriber.onCompleted(); }
}).subscribe(new Observer<Drawable>() {
@Override public void onNext(Drawable drawable) {
imageView.setImageDrawable(drawable); }
@Override public void onCompleted() { }
@Override public void onError(Throwable e) {
Toast.makeText(activity, "Error!", Toast.LENGTH_SHORT).show(); }});`
5.线程控制Scheduler
5.1 线程类型
- Schedulers.immediate(): 直接在当前线程运行，相当于不指定线程。这是默认的 Scheduler。
- Schedulers.newThread(): 总是启用新线程，并在新线程执行操作。
- Schedulers.io(): I/O 操作（读写文件、读写数据库、网络信息交互等）所使用的 Scheduler。行为模式和 newThread()差不多，区别在于 io()的内部实现是是用一个无数量上限的线程池，可以重用空闲的线程，因此多数情况下 io()比 newThread()更有效率。不要把计算工作放在 io()中，可以避免创建不必要的线程。
- Schedulers.computation(): 计算所使用的 Scheduler。这个计算指的是 CPU 密集型计算，即不会被 I/O 等操作限制性能的操作，例如图形的计算。这个 Scheduler 使用的固定的线程池，大小为 CPU 核数。不要把I/O 操作放在 computation()中，否则 I/O 操作的等待时间会浪费 CPU。
- AndroidSchedulers.mainThread()：它指定的操作将在 Android 主线程运行。
5.2 例子
Observable.just(1, 2, 3, 4) .subscribeOn(Schedulers.io()) // 指定 subscribe() 发生在 IO 线程
.observeOn(AndroidSchedulers.mainThread()) // 指定 Subscriber 的回调发生在主线程
.subscribe(new Action1<Integer>() {
@Override public void call(Integer number) {
Log.d(tag, "number:" + number); } });
up:后台读取数据，主线程显示。
int drawableRes = ...; ImageView imageView = ...; Observable.create(new OnSubscribe<Drawable>() { @Override public void call(Subscriber<? super Drawable> subscriber) { Drawable drawable = getTheme().getDrawable(drawableRes)); subscriber.onNext(drawable); subscriber.onCompleted(); } }) .subscribeOn(Schedulers.io()) // 指定 subscribe() 发生在 IO 线程 .observeOn(AndroidSchedulers.mainThread()) // 指定 Subscriber 的回调发生在主线程 .subscribe(new Observer<Drawable>() { @Override public void onNext(Drawable drawable) { imageView.setImageDrawable(drawable); } @Override public void onCompleted() { } @Override public void onError(Throwable e) { Toast.makeText(activity, "Error!", Toast.LENGTH_SHORT).show(); } });
加载图片用io线程，显示用main线程，不会造成界面卡顿。
6.变换-map
Observable.just("images/logo.png") // 输入类型 String .map(new Func1<String, Bitmap>() { @Override public Bitmap call(String filePath) { // 参数类型 String return getBitmapFromPath(filePath); // 返回类型 Bitmap } }) .subscribe(new Action1<Bitmap>() { @Override public void call(Bitmap bitmap) { // 参数类型 Bitmap showBitmap(bitmap); } });
map将string转换成bitmap。
Student[] students = ...; Subscriber<Course> subscriber = new Subscriber<Course>() { @Override public void onNext(Course course) { Log.d(tag, course.getName()); } ... }; Observable.from(students) .flatMap(new Func1<Student, Observable<Course>>() { @Override public Observable<Course> call(Student student) { return Observable.from(student.getCourses()); } }) .subscribe(subscriber);
flatmap将组拆分执行。
That's All
