RxJava之组合操作符

RxJava之组合操作符

      

       在实际开发过程中，实现一个功能，需要通过多个线程来处理。比如，房间温控监视仪需要监视不同房间的温度，温度传感器会实时传递并保存至数据库，意味着我们需要处理多个Observables。在这种情况下，该如何处理这些Observables呢？本篇博客，我们将学习组合操作符，了解如何同时处理多个Observables来创建我们想要的Observable。

merge

    merge操作符将两个甚至更多的Observables合并到一个发射的数据项里，并发射出去。
    merge操作符的流程图如下：

    示例代码:

        List<Student> list_0 = new ArrayList<>();List<Student> list_1 = new ArrayList<>();list_0.add(new Student("Merge-A11", "20", "1101"));list_0.add(new Student("Merge-A12", "23", "1102"));list_0.add(new Student("Merge-A13", "22", "1103"));list_0.add(new Student("Merge-A14", "21", "1104"));list_0.add(new Student("Merge-A15", "20", "1105"));list_1.add(new Student("Merge-B11", "20", "1101"));list_1.add(new Student("Merge-B12", "23", "1102"));list_1.add(new Student("Merge-B13", "22", "1103"));Observable<Student> obs_0 = Observable.from(list_0);Observable<Student> obs_1 = Observable.from(list_1);Observable<Student> obsMerge = (obs_0, obs_1);obsMerge.subscribe(new Observer<Student>() {@Overridepublic void onCompleted() {}@Overridepublic void onError(Throwable e) {}@Overridepublic void onNext(Student student) {mAdaStu.addData(student);}});

    
       如示例代码，我们创建了两个Observable数据列表obs_0和obs_1，使用()，将obs_0和obs_1合并，并创建新的Observables列表 obsMerge，它在单个可观测序列中发射源Observ