RXjava及RxJava操作符的学习

RxJava是响应式编程，是一种链式编程，不受逻辑影响。

 

第一步：创建连载小说（被观察者）

//被观察者
        Observable novel=Observable.create(new ObservableOnSubscribe<String>() {
            @Override
            public void subscribe(ObservableEmitter<String> emitter) throws Exception {
                emitter.onNext("连载1");
                emitter.onNext("连载2");
                emitter.onNext("连载3");
                emitter.onComplete();
            }
        });

第二步：创建读者（观察者）

//观察者
        Observer<String> reader=new Observer<String>() {
            @Override
            public void onSubscribe(Disposable d) {
                mDisposable=d;
                Log.e(TAG,"onSubscribe");
            }

            @Override
            public void onNext(String value) {
                if ("2".equals(value)){
                    mDisposable.dispose();
                    return;
                }
                Log.e(TAG,"onNext:"+value);
            }

            @Override
            public void onError(Throwable e) {
                Log.e(TAG,"onError="+e.getMessage());
            }

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

第三步：订阅

novel.subscribe(reader);
//或者
novel.subscribe(subscriber);

RxJava学习博客

https://blog.csdn.net/rookie_small/article/details/68488420

RxJava操作符

https://blog.csdn.net/qq_30172399/article/details/89948746