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   @Override15   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       @Override38       public void call(Object o) {39       System.out.println( "rx-- " + o );40       }41     }) ;42 43   }44 }

运行结果

RxJava 和 RxAndroid 二 images/loading.gif' data-original="http://images2015.cnblogs.com/blog/605655/201605/605655-20160517190018560-1075954286.png" />