Android响应式编程开发RxAndroid（2）：简单例程的Android改造


Android响应式编程开发RxAndroid（2）：简单例程的Android改造附录1的Android响应式编程开发代码规范，遵循的是RxJava样式，可以正常运行。换一种方式，把响应式编程写的更Android化，下面对附录1的例程改造，换一种方式实现。用一个TextView显示最终的处理结果（在onComplete里面处理结果）。
Java代码：
package zhangphil.app;

import android.app.Activity;
import android.os.Bundle;
import android.os.SystemClock;
import android.util.Log;
import android.widget.TextView;

import java.util.ArrayList;
import java.util.List;

import io.reactivex.Observable;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.observers.DisposableObserver;
import io.reactivex.schedulers.Schedulers;

public class MainActivity extends Activity {
//假设一个数据源
private String TAG = "zhangphil@csdn";
private List<String> lists = new ArrayList<>();

private DisposableObserver<List<String>> mDisposableObserver = new DisposableObserver<List<String>>() {
private String string = "";

@Override
public void onNext(List list) {
Log.d(TAG, "onNext - Start");

for (int i = 0; i < list.size(); i++) {
String s = String.valueOf(list.get(i));
string = string + s;
Log.d(TAG, string);

SystemClock.sleep(100);
}

Log.d(TAG, "onNext - End");
}

@Override
public void onComplete() {
Log.d(TAG, "onComplete");

text.setText(string);
}

@Override
public void onError(Throwable e) {
Log.e(TAG, e.toString(), e);
}
};

private TextView text;

@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
text = (TextView) findViewById(R.id.text);

for (int i = 0; i < TAG.length(); i++) {
lists.add(String.valueOf(TAG.charAt(i)));
}

//just作为输入驱动数据源
Observable.just(lists)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribeWith(mDisposableObserver);

Log.d(TAG,"onCreate结束");
}
}

代码运行输出：
02-28 15:04:53.135 25048-25048/zhangphil.app D/zhangphil@csdn: onCreate结束
02-28 15:04:53.135 25048-25048/zhangphil.app D/Activity: performCreate Call Injection manager
02-28 15:04:53.145 25048-25048/zhangphil.app I/InjectionManager: dispatchOnViewCreated > Target : zhangphil.app.MainActivity isFragment :false
02-28 15:04:53.145 25048-25048/zhangphil.app D/SecWifiDisplayUtil: Metadata value : SecSettings2
02-28 15:04:53.145 25048-25048/zhangphil.app D/ViewRootImpl: #1 mView = com.android.internal.policy.PhoneWindow$DecorView{591deef I.E...... R.....ID 0,0-0,0}
02-28 15:04:53.145 25048-25048/zhangphil.app D/zhangphil@csdn: onNext - Start
02-28 15:04:53.145 25048-25048/zhangphil.app D/zhangphil@csdn: z
02-28 15:04:53.245 25048-25048/zhangphil.app D/zhangphil@csdn: zh
02-28 15:04:53.345 25048-25048/zhangphil.app D/zhangphil@csdn: zha
02-28 15:04:53.445 25048-25048/zhangphil.app D/zhangphil@csdn: zhan
02-28 15:04:53.545 25048-25048/zhangphil.app D/zhangphil@csdn: zhang
02-28 15:04:53.645 25048-25048/zhangphil.app D/zhangphil@csdn: zhangp
02-28 15:04:53.745 25048-25048/zhangphil.app D/zhangphil@csdn: zhangph
02-28 15:04:53.855 25048-25048/zhangphil.app D/zhangphil@csdn: zhangphi
02-28 15:04:53.955 25048-25048/zhangphil.app D/zhangphil@csdn: zhangphil
02-28 15:04:54.045 25048-25048/zhangphil.app D/zhangphil@csdn: zhangphil@
02-28 15:04:54.145 25048-25048/zhangphil.app D/zhangphil@csdn: zhangphil@c
02-28 15:04:54.245 25048-25048/zhangphil.app D/zhangphil@csdn: zhangphil@cs
02-28 15:04:54.345 25048-25048/zhangphil.app D/zhangphil@csdn: zhangphil@csd
02-28 15:04:54.455 25048-25048/zhangphil.app D/zhangphil@csdn: zhangphil@csdn
02-28 15:04:54.555 25048-25048/zhangphil.app D/zhangphil@csdn: onNext - End
02-28 15:04:54.555 25048-25048/zhangphil.app D/zhangphil@csdn: onComplete

当在onNext里面的遍历结束后，在TextView里面才显示zhangphil@csdn。
附录：
1，《Android响应式编程RxAndroid（1）：简单例程》链接地址：http://blog.csdn.net/zhangphil/article/details/58593782