首页 > 代码库 > android学习笔记(2)--RxJava

android学习笔记(2)--RxJava

紧接上一篇博文,本篇介绍RxJava,一个实现异步操作的库

RxJava最核心的两个东西是Observables和Subscribers

1.Observables(被观察者,事件源)发出一系列事件

2.Subscribers(观察者)处理这些事件

这里的事件可以是任何你感兴趣的东西(触摸事件,web接口调用返回的数据等等)

一个Observable可以发出零个或者多个事件,知道结束或者出错。

每发出一个事件,就会调用它的Subscriber的onNext方法,最后调用Subscriber.onNext()或者Subscriber.onError()结束。

Rxjava的看起来很想设计模式中的观察者模式,但是有一点明显不同,那就是如果一个Observerble没有任何的的Subscriber,那么这个Observable是不会发出任何事件的。

 

eg.一个用RxJava来打印Hello World的程序

1.创建一个Observable:调用Observable.create
 
 
Observable<String> myObservable = Observable.create(  
    new Observable.OnSubscribe<String>() {  
        @Override  
        public void call(Subscriber<? super String> sub) {  
            sub.onNext("Hello, world!");  
            sub.onCompleted();  
        }  
    }  
);  

也可以用简化版本:

Observable<String> myObservable = Observable.just("Hello, world!")

这里定义的Observable对象仅仅发出一个Hello World字符串,然后就结束。

2.创建Subscriber,用于处理Observable对象发出的字符串。

Subscriber<String> mySubscriber = new Subscriber<String>() {  
    @Override  
    public void onNext(String s) { System.out.println(s); }  
  
    @Override  
    public void onCompleted() { }  
  
    @Override  
    public void one rror(Throwable e) { }  
};  

简化版本:

Action1<String> onNextAction = new Action1<String>() {  
    @Override  
    public void call(String s) {  
        System.out.println(s);  
    }  
};  

subscriber仅仅就是打印observable发出的字符串。

3.subscribe函数将myObservable对象和mySubscriber对象关联。完成了subscriber对observable的订阅。

myObservable.subscribe(mySubscriber);  

如果之前用的Action1的类,那么用下面的方法订阅:

myObservable.subscribe(onNextAction);  

合成之前的简洁版本,可以这样写:

Observable.just("Hello, world!")  
    .subscribe(new Action1<String>() {  
        @Override  
        public void call(String s) {  
              System.out.println(s);  
        }  
    });

4.完成。现在mySubscriber订阅了myObservable,myObservable就是调用mySubscriber对象的onNext和onComplete方法,mySubscriber就会打印出Hello World!

 

 

以上是简单的RxJava的用法,下面来看一下MovieGuide中是如何使用RxJava:

在MovieGuide中,RxJava主要在迭代器类中使用

//todo

 

 

android学习笔记(2)--RxJava