返回 登录
0

【菜鸟教程】Android studio 使用Rxjava/RxAndroid简单小例子【更新帖】

Rxjava现在挺火,总的来说就是来解决异步操作的。
具体详细解释,csdn有的是,不赘述,这里只是提供例子。我也刚接触,大神勿喷请绕道。

2016-09-13 最简单的例子(循环1秒加载输出日志一次),开篇

第一步在你的build.grade里面的dependencies里面加上:

compile 'io.reactivex:rxandroid:1.2.1'
compile 'io.reactivex:rxjava:1.1.6'

第二步直接用啦!

Observer<String> observer = new Observer<String>() {
            @Override
            public void onNext(String s) {
                new Thread(){
                    public void run() {
                        for (int i = 0;i>=0;i++){
                            try {
                                sleep(1000);
                                Log.d("rxjava", "测试"+i);
                            } catch (InterruptedException e) {
                                e.printStackTrace();
                            }
                        }
                    }
                }.start();
            }

            @Override
            public void onCompleted() {
                Log.d("rxjava", "Completed!");
            }

            @Override
            public void onError(Throwable e) {
                Log.d("rxjava", "Error!");
            }
        };

Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
            @Override
            public void call(Subscriber<? super String> subscriber) {
                subscriber.onNext("Hello");
                subscriber.onCompleted();
            }
        });
observable.subscribe(observer);

图片描述

评论