RxJava 和 RxAndroid 二

 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 }