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

太过爱你忘了你带给我的痛 2023-10-17 11:11 67阅读 0赞

**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][zhangphil_csdn]。

附录：  
1，《Android响应式编程RxAndroid（1）：简单例程》链接地址：[http://blog.csdn.net/zhangphil/article/details/58593782][http_blog.csdn.net_zhangphil_article_details_58593782]

[zhangphil_csdn]: mailto:zhangphil@csdn
[http_blog.csdn.net_zhangphil_article_details_58593782]: http://blog.csdn.net/zhangphil/article/details/58593782