码迷,mamicode.com
首页 > 编程语言 > 详细

RXJAVA的使用

时间:2016-05-28 21:52:11      阅读:169      评论:0      收藏:0      [点我收藏+]

标签:

一、什么是观察者模式

就是观察者告诉被观察者我需要你的某种状态,当被观察者做出动作的时候,观察者立刻做出相应反应。所以步骤就是,创建被观察者,逻辑是它要执行的动作。创建观察者,当被观察者做出动作的时候,观察者该怎么做。之后观察者要盯着观察者,这就是连接。

二、RXJAVA中的观察者和被观察者

Observable(被观察者)     Observer/Subscribe(观察者)

三、创建 被观察者  和 观察者 并建立连接

技术分享
  //创建被观察者,运用OnSubscribe创造自己的逻辑在其中
        Observable observable = Observable.create(new Observable.OnSubscribe<String>(){
            @Override
            public void call(Subscriber<? super String> subscriber) {
                subscriber.onNext("123");
                subscriber.onNext("321");
            }
        });
        //观察者,当被观察者做出动作了,观察者要做的事情逻辑
        Observer<String> observer = new Observer<String>() {
            @Override
            public void onCompleted() {

            }

            @Override
            public void onError(Throwable e) {

            }

            @Override
            public void onNext(String s) {
                //当返回数据的时候
            }
        };
        //观察者和被观察者建立连接
        observable.subscribe(observer);
使用

 

RXJAVA的使用

标签:

原文地址:http://www.cnblogs.com/rookiechen/p/5538356.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!