android学习笔记（2）--RxJava

时间：2016-11-15 13:43:12 阅读：241 评论：0 收藏：0 [点我收藏+]

标签：important 学习笔记 throw tools 触摸 completed 出错 bar display

紧接上一篇博文，本篇介绍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 onError(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

标签：important 学习笔记 throw tools 触摸 completed 出错 bar display

原文地址：http://www.cnblogs.com/summerxt/p/6065192.html

踩

(0)

评论一句话评论（0）

分享档案

更多>

2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)

周排行