Rxjava2

1.RxJava2的基本介绍

1.1核心思想：

• 观察者模式
  观察者(接收器)
  被观察者(发射器)
• 响应式编程
  基于异步数据流的编程模式，数据流就像一条河：它可以被观测，被过滤，被操作，或者为新的消费者与另外一条流合并为一条新的流

1.2 简单使用

• create
  产生一个观察者对象

Observable.create(new ObservableOnSubscribe<Object>() {
            @Override
            public void subscribe(ObservableEmitter<Object> emitter) throws Exception {
                  emitter.onNext("发送事件");
            }
        });

1.3 操作符

在被观察者处理数据后会调用观察者的相关方法(即被观察者发送事件给观察者)。而在这个处理过程中，可以使用rxjava内置的方法来进行数据的过滤处理

• compose
  需要配合transformer使用，将obervableA转化为obervableB，即保证链式调用的完整性而不需要中断。

getRxApi().login(account, password)
                .compose(RxSchedulers.io_main())//传入Transformer对象
                .subscribe(observable);

public static ObservableTransformer io_main() {
       return new ObservableTransformer() {
           @Override
           public ObservableSource apply(Observable upstream) {
               return upstream
                       .subscribeOn(Schedulers.io())
                       .unsubscribeOn(Schedulers.io())
                       .observeOn(AndroidSchedulers.mainThread());
           }
       };
    }

• interval
  在指定的时间间隔持续发送从0开始递增的事件

Observable.interval(1,2, TimeUnit.SECONDS);// 0在1秒后发送，之后每隔2秒发送一次事件(1,2....)

• take
  发送指定

 Observable.interval(1，2, TimeUnit.SECONDS)
        .take(3);//发送3次事件就终止(1,2,3)

• map

   Observable.interval(0, TimeUnit.SECONDS)
        .map(new Function<Long, String>() {
            @Override
            public String apply(Long aLong) throws Exception {
                return String.valueOf(aLong);//将Long型元素转化为字符串
            }
        });

• flatMap

//有多个学生，每个学生选修了多门课程。打印出每个学生选修的课程名称
Observable.from(students)
                .flatMap(new Func1<Student, Observable<Course>>() {
                    @Override
                    public Observable<Course> call(Student student) {
                        return Observable.from(student.getCoursesList());
                    }
                })
                .subscribe(new Action1<Course>() {
                    @Override
                    public void call(Course course) {
                        Log.i(TAG, course.getName());
                    }
                });

• just
  与create不同的是，它会在创建被观察者对象之后直接调用onNext方法

Observable.just("发送数据");

• combineLatest
  将两个发射器的结果进行合并(多用于表单校验)

    //结合Rxbinding使用
    Observable<CharSequence> ObservableName  = RxTextView.textChanges(etUsername);
    Observable<CharSequence> ObservablePassword = RxTextView.textChanges(etPassword);
    Observable.combineLatest(ObservableName, ObservablePassword, new BiFunction<CharSequence, CharSequence, Boolean>() {
            @Override
            public Boolean apply(CharSequence charSequence, CharSequence charSequence2) throws Exception {
                String passowrd = inputPassword.getEditText().getText().toString().trim();
                return !TextUtils.isEmpty(inputUsername.getEditText().getText().toString().trim())
                        && !TextUtils.isEmpty(passowrd);
            }
        }).subscribe(new Consumer<Boolean>() {
            @Override
            public void accept(Boolean aBoolean) throws Exception {
                tvLogin.setEnabled(aBoolean);
            }
        });