Android响应式编程RxAndroid（1）：简单例程

package zhangphil.app;import android.app.Activity;import android.os.Bundle;import android.util.Log;import java.util.ArrayList;import java.util.List;import io.reactivex.Observable;import io.reactivex.Observer;import io.reactivex.android.schedulers.AndroidSchedulers;import io.reactivex.disposables.Disposable;import io.reactivex.schedulers.Schedulers;public class MainActivity extends Activity {    //假设一个数据源    PRivate String TAG = "zhangphil@csdn";    Observer<List<String>> observer = new Observer<List<String>>() {        @Override        public void onSubscribe(Disposable d) {            //Log.d(TAG, d.toString());        }        @Override        public void onNext(List list) {            Log.d(TAG, "onNext - Start");            for (int i = 0; i < list.size(); i++) {                Log.d(TAG, String.valueOf(list.get(i)));            }            Log.d(TAG, "onNext - End");        }        @Override        public void onComplete() {            Log.d(TAG, "onComplete");        }        @Override        public void onError(Throwable e) {            Log.e(TAG, e.toString(), e);        }    };    @Override    protected void onCreate(Bundle savedInstanceState) {        super.onCreate(savedInstanceState);        List<String> lists = new ArrayList<>();        for (int i = 0; i < TAG.length(); i++) {            lists.add(String.valueOf(TAG.charAt(i)));        }        //为一个数据源增加一个观察者        //观察者是observer，observer吐出观察到的数据        Observable                .just(lists)                .subscribeOn(Schedulers.io())                .observeOn(AndroidSchedulers.mainThread())                .subscribe(observer);    }}代码运行输出：
02-28 13:55:00.571 10845-10845/zhangphil.app D/zhangphil@csdn: onNext - Start02-28 13:55:00.571 10845-10845/zhangphil.app D/zhangphil@csdn: z02-28 13:55:00.571 10845-10845/zhangphil.app D/zhangphil@csdn: h02-28 13:55:00.571 10845-10845/zhangphil.app D/zhangphil@csdn: a02-28 13:55:00.571 10845-10845/zhangphil.app D/zhangphil@csdn: n02-28 13:55:00.571 10845-10845/zhangphil.app D/zhangphil@csdn: g02-28 13:55:00.571 10845-10845/zhangphil.app D/zhangphil@csdn: p02-28 13:55:00.571 10845-10845/zhangphil.app D/zhangphil@csdn: h02-28 13:55:00.571 10845-10845/zhangphil.app D/zhangphil@csdn: i02-28 13:55:00.571 10845-10845/zhangphil.app D/zhangphil@csdn: l02-28 13:55:00.571 10845-10845/zhangphil.app D/zhangphil@csdn: @02-28 13:55:00.571 10845-10845/zhangphil.app D/zhangphil@csdn: c02-28 13:55:00.571 10845-10845/zhangphil.app D/zhangphil@csdn: s02-28 13:55:00.571 10845-10845/zhangphil.app D/zhangphil@csdn: d02-28 13:55:00.571 10845-10845/zhangphil.app W/ActivityThread: AppLock checkAppLockState isAppLocked = false pkgName = zhangphil.app showWhenLocked = false02-28 13:55:00.571 10845-10845/zhangphil.app D/zhangphil@csdn: n02-28 13:55:00.571 10845-10845/zhangphil.app D/zhangphil@csdn: onNext - End02-28 13:55:00.571 10845-10845/zhangphil.app D/zhangphil@csdn: onComplete