RxJava解析

Observable.create(

//原始被观察者

        new ObservableOnSubscribe() {

@Override

    public void subscribe(ObservableEmitter emitter)throws Exception {

emitter.onNext("xxx");

}

})

.subscribeOn(Schedulers.io())

.subscribe(

//最终观察者

                new Observer() {

@Override

            public void onSubscribe(Disposable d) {

}

@Override

            public void onNext(String s) {

}

@Override

            public void onError(Throwable e) {

}

@Override

            public void onComplete() {

}

});

rx流程

1.每个切块都有自己的被观察者，观察者。并用source持有上游被观察者，在开始创建的时候传入。

2.遇见最终观察者调用subscribeActual()方法，创建自己的观察者并用observer持有下游观察者。调用source.subscribe(parent)方法。source时上游被观察。

3.遇到最开始的被观察者对象调用在subscribe()方法中调用parent.onNext()方法,向下游传递，在下游onNext()方法中执行完自己的需求后使用observer.onNext()继续传递。

设计模式：

1.观察者模式

2.使用自己的观察者包装下游观察者是装饰者模式

3.通过构造器传递上游被观察者，执行subscribeActual方法传递下游观察者，是模版设计模式