附录1的Android响应式编程开发代码规范，遵循的是RxJava样式，可以正常运行。换一种方式，把响应式编程写的更Android化，下面对附录1的例程改造，换一种方式实现。用一个TextView显示最终的处理结果（在onComplete里面处理结果）。
Java代码：
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
