RxJava Observable用法

雨点打透心脏的1/2处 2022-11-06 01:52 114阅读 0赞

#### 一、RxJava简介 ####

一般我们进行耗时任务，如网络、数据库查询、复杂计算等等，我们都回开启一个线程，然后通过接口回调，获取我们的结果。 但随着我们业务逻辑的越来越复杂，我们就会陷入一个回调地狱，回调里面还有回调，在日后我们维护代码来说简直是噩梦。**RxJava的出现正式为了解决这个问题而生的，它支持链式调用！**

#### 二、基本用法 ####

##### 1、创建Observable（被观察者） #####

//创建Observable对象
    // 监听观察者订阅，从源码中可以看出，一旦调用了subscribe方法， 即会回调call()方法，其中的observer即订阅传进去观察者new Observer<Integer>()
    Observable observableInteger = Observable.create(new OnSubscribe<Integer>() { 
       @Override
        public void call(Subscriber<? super Integer> observer) { 
            for (int i = 1; i < 5; i++) { 
                //观察者发送数据
                observer.onNext(i);
            }
            observer.onCompleted();
        }
    });

#### 2、注册观察者 ####

创建Observable（被观察者）之后，我们的观察者实现订阅（注册）即可接收被观察者传过来的数据：

//观察者/订阅者注册（Subscriber是Observer和Subscription实现抽象类）
    Subscription subscription = observabelInteger.subscribe(new Observer<Integer>() { 
         @Override
         public void onCompleted() { 
             //完成
         }
         @Override
         public void onError(Throwable e) { 
             //发生错误
         }
      
         @Override
         public void onNext(Integer item) { 
         	//观察者接收数据
            //TODO
         }
     });
     //解除订阅关系
     subscription.unsubscribe();