zoukankan      html  css  js  c++  java
  • RxJava 学习笔记(一)

    最近Android6.0的权限问题,要把之前的APP进行改造,用到了RxPermission框架!之前了解过RXJAVA,但是由于之前项目一直没有使用这个框架,所以也就一直搁置了。正好Rxpermission框架里用到了RXJAVA的内容,索性就学习了一下。

    在正文开始之前的最后,放上 GitHub 链接和引入依赖的 gradle 代码: Github: 
    https://github.com/ReactiveX/RxJava 
    https://github.com/ReactiveX/RxAndroid 
    引入依赖: 

    compile 'io.reactivex:rxjava:1.0.14' 
    compile 'io.reactivex:rxandroid:1.0.1' 

    RxJava 好在哪(很多blog文都有这句话,随大流,copy过来)

    换句话说,『同样是做异步,为什么人们用它,而不用现成的 AsyncTask / Handler / XXX / ... ?』

    一个词:简洁

    异步操作很关键的一点是程序的简洁性,因为在调度过程比较复杂的情况下,异步代码经常会既难写也难被读懂。 Android 创造的 AsyncTask 和Handler ,其实都是为了让异步代码更加简洁。RxJava 的优势也是简洁,但它的简洁的与众不同之处在于,随着程序逻辑变得越来越复杂,它依然能够保持简洁。

    Rxjava基本原理就是观察者(ObServer)通过(Subscribe)订阅被观察者(Observable),看一个简单的例子

    1.首先创建订阅者Observer

    Observer<String> observer = new Observer<String>() {
                @Override
                public void onCompleted() {
                    //任务完成时出发
                }
    
                @Override
                public void onError(Throwable e) {
                    //队列发生异常时出发
                }
    
                @Override
                public void onNext(String s) {
                    Toast.makeText(MainActivity.this, s,  Toast.LENGTH_SHORT).show();
                }
            };    

    2.创建被观察者Observable

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

    3.通过Subscibe完成双方之间的订阅关系进行关联

    observable.subscribe(observer);

    Create() 方法是 RxJava 最基本的创造事件序列的方法。基于这个方法, RxJava 还提供了一些方法用来快捷创建事件队列,例如:

    • just(T...): 将传入的参数依次发送出来。
      Observable observable = Observable.just("hello","h1","h2","....");
    • from(T[]) / from(Iterable<? extends T>) : 将传入的数组或 Iterable 拆分成具体对象后,依次发送出来
    String[] strs = {"小明", "小红", "小芳"};
    Observable observable = Observable.from(strs);

    或者传入列表

    ArrayList<String> strLists = new ArrayList<>();
    strLists.add("小明");
    strLists.add("小明1");
    strLists.add("小明2");
    Observable observable = Observable.from(strLists);

     这些都可以和上面的onCreate()达到相同的效果

     随着学习的深入再继续下一步。今天先消化这些,哈哈哈

     

     

     

     

     

     

     

  • 相关阅读:
    PHP如何获取内网IP
    开源的世界并不纯净
    在linux下玩上了第一人称射击
    终于,在linux下上网了
    我的理想
    vista是什么
    我傻了一阵子
    又是大端小端!!!
    谈谈最近的编程状态
    如何快速发布你的C++Builder程序
  • 原文地址:https://www.cnblogs.com/sy171822716/p/6216850.html
Copyright © 2011-2022 走看看