本文共 3404 字，大约阅读时间需要 11 分钟。

RxJava ������������������

1. ���������������������������

RxJava ��������������������������������������������������������������������������������������������������� RxJava ������������������������������������

• ������������Observer���������������������������������������������������
• ������������������Observable������������������������������������������������

Observables ������������������������������ Observers ������������������������������������������������������

2. ������������Scheduler���

������������Scheduler������ RxJava ���������������������������������������������������������������������������������������������������������������������������������

• Schedulers.immediate()������������������������������������
• Schedulers.newThread()���������������������������������������������������������main������������������������
• Schedulers.io()���������������I/O������������������������������������������������ RxJava������������������������������������������������
• Schedulers.computation()��������� CPU ��������������������������������������� CPU ���������������
• AndroidSchedulers.mainThread()��������������������������������������������������� UI���������

������������������������������������������������������������������������������������������

3. ������������

������������������������������������������������������������������������������������RxJava ��������������������������������� map���flatMap ���������������������������������������������������������

• map()���������������������������������������������������������
• flatMap()��������������������������������������������� Observable ��������������������������������������� Observable ������

������ map ��� flatMap������������������������������������������������������������������������������������

4. ������������

��������������������� Observable ��������������������������� RxJava ��������� compose ��������������������������������������������������������������������������������������� compose������������������������������������������������������������������������������������������������������������

5. ������������������

���������������������������������������������

������������������������������������ UI ������������

Observable.create(new OnSubscribe
   
    () {
    @Override
    public void call(Subscriber
    
      subscriber) {
        Drawable drawable = getTheme().getDrawable(drawableRes);
        subscriber.onNext(drawable);
        subscriber.onCompleted();
    }
}).subscribeOn(Schedulers.io())  // ������ subscribe() ��� IO ������������
.observeOn(AndroidSchedulers.mainThread())  // ������������������������������
.subscribe(new Observer
     
      () {
    @Override
    public void onNext(Drawable drawable) {
        // ������������
        imageView.setImageDrawable(drawable);
    }
    @Override
    public void onError(Throwable e) {
        // ������������
        Toast.makeText(activity, "Error!", Toast.LENGTH_SHORT).show();
    }
});
     
    
   

6. ������������

• ������������������������������������������������������������������������������������������������������
• ������������ unsubscribe() ������������������������������������������
• ��������� computation() ���������������I/O������������������������������
• ������ RxJava���������������������������������������������������������������������������

������������������������������������������������������ RxJava ���������������������������������������������������������