rxjava2学习笔记(1)

时间：2017-04-06 19:52:06 阅读：261 评论：0 收藏：0 [点我收藏+]

标签：概念入门 hello https blog 地址 world 表示逻辑

1.什么是RxJava?

　　简单,清晰的多线程编程框架.可方便的写出维护性高,逻辑清晰的Java程序.

2.什么是观察者模式?

　　入门教程讲这种高大上抽象概念都是耍流氓!

3.开始

　　3.1github地址

　　　　https://github.com/ReactiveX/RxJava

　　　　https://github.com/ReactiveX/RxAndroid

　　3.2添加依赖:

　　　　compile ‘io.reactivex.rxjava2:rxandroid:2.0.1‘

　　　　compile ‘io.reactivex.rxjava2:rxjava:2.0.8‘

　　　　以上是rxjava的最新版本.

4.helloworld程序

public class MainActivity extends AppCompatActivity {
    private static final String TAG  = "MainActivity";
    @Override
    protected void onCreate(final Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        Observable.create(new ObservableOnSubscribe<Integer>(){
            @Override
            public void subscribe(@NonNull ObservableEmitter<Integer> e) throws Exception {
                int i = 0;
                while(i < 5) {
                    e.onNext(i++);
                    Log.i(TAG, "subscribe: "+i);
                }
                e.onComplete();
//                e.onError(new Throwable("onError"));
                while(i < 10) {
                    e.onNext(i++);
                    Log.i(TAG, "subscribe: "+i);
                }


            }
        }).subscribe(new Observer<Integer>(){
            @Override
            public void onSubscribe(Disposable d) {
                Log.i(TAG, "onSubscribe: ");
            }

            @Override
            public void onNext(Integer integer) {
                Log.i(TAG, "onNext: " + integer);
            }

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

            @Override
            public void onComplete() {
                Log.i(TAG, "onComplete: ");
            }
        });

    }
}