Rxjava源码分析_qq_26414049的博客

一、RxJava案例和流程   

    // 结论： new ObservableCreate() {source == 自定义source}

    // 2：Observable创建过程 源码分析
    Observable.create(
            // 自定义source
            new ObservableOnSubscribe<String>() {
                @Override
                public void subscribe(ObservableEmitter<String> emitter) throws Exception {
                    // 发射器.onNext
                    emitter.onNext("A");
                }
            })
            // 3：subscribe订阅过程 源码分析
            // ObservableCreate. subscribe
            .subscribe(
                    // 自定义观察者
                    // 1：Observer 源码看看
                    new Observer<String>() {
                        @Override
                        public void onSubscribe(Disposable d) {
                        }

                        @Override
                        public void onNext(String s) {
                        }

                        @Override
                        public void onError(Throwable e) {
                        }

                        @Override
                        public void onComplete() {
                        }
                    });
}一、RxJava案例和流程   

    // 结论： new ObservableCrea