RxJava 和 RxAndroid 二

前言：对Rx不了解的朋友可以先看我的第一篇博文 RxJava 和 RxAndroid ，是对Rxjava的基本介绍

1、merge操作符，合并观察对象

 1 package app.com.myapplication;
 2
 3 import android.support.v7.app.AppCompatActivity;
 4 import android.os.Bundle;
 5
 6 import java.util.ArrayList;
 7 import java.util.List;
 8
 9 import rx.Observable;
10 import rx.functions.Action1;
11
12 public class MergeActivity extends AppCompatActivity {
13
14     @Override
15     protected void onCreate(Bundle savedInstanceState) {
16         super.onCreate(savedInstanceState);
17         setContentView(R.layout.activity_merge);
18
19         List<String> list1 = new ArrayList<>() ;
20         List<String> list2 = new ArrayList<>() ;
21
22         list1.add( "1" ) ;
23         list1.add( "2" ) ;
24         list1.add( "3" ) ;
25
26         list2.add( "a" ) ;
27         list2.add( "b" ) ;
28         list2.add( "c" ) ;
29
30         Observable observable1 = Observable.from( list1 ) ;
31         Observable observable2 = Observable.from( list2 ) ;
32
33         //合并数据  先发送observable2的全部数据，然后发送 observable1的全部数据
34         Observable observable = Observable.merge( observable2 , observable1 ) ;
35
36         observable.subscribe(new Action1() {
37             @Override
38             public void call(Object o) {
39              System.out.println( "rx-- " + o );
40             }
41         }) ;
42
43     }
44 }

运行结果